lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2912] Fix CompactionPlanOperator typo (#4187)

Browse Source 
Co-authored-by: yuzhaojing <yuzhaojing@bytedance.com>
This commit is contained in:
yuzhaojing
2021-12-11 01:32:53 +08:00
committed by GitHub
parent be368264f4
commit 3ad9b121f1
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
View File

@@ -98,7 +98,7 @@ public class CompactionPlanOperator extends AbstractStreamOperator<CompactionPla
} }
private void scheduleCompaction(HoodieFlinkTable<?> table, long checkpointId) throws IOException { private void scheduleCompaction(HoodieFlinkTable<?> table, long checkpointId) throws IOException {
// the last instant takes the highest priority. // the first instant takes the highest priority.
Option<HoodieInstant> firstRequested = table.getActiveTimeline().filterPendingCompactionTimeline() Option<HoodieInstant> firstRequested = table.getActiveTimeline().filterPendingCompactionTimeline()
.filter(instant -> instant.getState() == HoodieInstant.State.REQUESTED).firstInstant(); .filter(instant -> instant.getState() == HoodieInstant.State.REQUESTED).firstInstant();
if (!firstRequested.isPresent()) { if (!firstRequested.isPresent()) {