[hudi] branch master updated: [HUDI-2912] Fix CompactionPlanOperator typo (#4187)

[yihua]

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 <32435329+yuzhaoj...@users.noreply.github.com>
AuthorDate: Sat Dec 11 01:32:53 2021 +0800

    [HUDI-2912] Fix CompactionPlanOperator typo (#4187)
    
    Co-authored-by: yuzhaojing <yuzhaoj...@bytedance.com>
---
 .../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()) {