This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 3ad9b12 [HUDI-2912] Fix CompactionPlanOperator typo (#4187)
3ad9b12 is described below
commit 3ad9b121f15c3c4f0eadba799dd4d96d5b9d6b1f
Author: yuzhaojing <[email protected]>
AuthorDate: Sat Dec 11 01:32:53 2021 +0800
[HUDI-2912] Fix CompactionPlanOperator typo (#4187)
Co-authored-by: yuzhaojing <[email protected]>
---
.../main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
b/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
index f6dd241..6df11fe 100644
---
a/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
+++
b/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java
@@ -98,7 +98,7 @@ public class CompactionPlanOperator extends
AbstractStreamOperator<CompactionPla
}
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()
.filter(instant -> instant.getState() ==
HoodieInstant.State.REQUESTED).firstInstant();
if (!firstRequested.isPresent()) {
