lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

Fix bug for schedule compaction manually

Browse Source
This commit is contained in:
v-zhangjc9
2023-10-30 15:27:58 +08:00
parent 2188b8ed8a
commit 181df2240a
1 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/HoodieFlinkCompactor.java
View File

@@ -226,9 +226,7 @@ public class HoodieFlinkCompactor {
// checks the compaction plan and do compaction. // checks the compaction plan and do compaction.
if (cfg.schedule) { if (cfg.schedule) {
Option<String> compactionInstantTimeOption = CompactionUtil.getCompactionInstantTime(metaClient); boolean scheduled = writeClient.scheduleCompaction(Option.empty()).isPresent();
if (compactionInstantTimeOption.isPresent()) {
boolean scheduled = writeClient.scheduleCompactionAtInstant(compactionInstantTimeOption.get(), Option.empty());
if (!scheduled) { if (!scheduled) {
// do nothing. // do nothing.
LOG.info("No compaction plan for this job "); LOG.info("No compaction plan for this job ");
@@ -237,7 +235,6 @@ public class HoodieFlinkCompactor {
} }
table.getMetaClient().reloadActiveTimeline(); table.getMetaClient().reloadActiveTimeline();
} }
}
// fetch the instant based on the configured execution sequence // fetch the instant based on the configured execution sequence
HoodieTimeline pendingCompactionTimeline = table.getActiveTimeline().filterPendingCompactionTimeline(); HoodieTimeline pendingCompactionTimeline = table.getActiveTimeline().filterPendingCompactionTimeline();