From 548a418f486494091e1001aec0a733fd89ca8fbe Mon Sep 17 00:00:00 2001 From: yuzhaojing Date: Thu, 2 Dec 2021 14:34:11 +0800 Subject: [PATCH] [HUDI-2912] Fix CompactionPlanOperator typo --- .../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 f6dd241ec069c..6df11fe2242f3 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 void notifyCheckpointComplete(long checkpointId) { } private void scheduleCompaction(HoodieFlinkTable table, long checkpointId) throws IOException { - // the last instant takes the highest priority. + // the first instant takes the highest priority. Option firstRequested = table.getActiveTimeline().filterPendingCompactionTimeline() .filter(instant -> instant.getState() == HoodieInstant.State.REQUESTED).firstInstant(); if (!firstRequested.isPresent()) {