From 3ad9b121f15c3c4f0eadba799dd4d96d5b9d6b1f Mon Sep 17 00:00:00 2001 From: yuzhaojing <32435329+yuzhaojing@users.noreply.github.com> Date: Sat, 11 Dec 2021 01:32:53 +0800 Subject: [PATCH] [HUDI-2912] Fix CompactionPlanOperator typo (#4187) Co-authored-by: yuzhaojing --- .../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 f6dd241ec..6df11fe22 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 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()) {