From 65fd7f9ce6e2c3448433c683c034694df3b12c85 Mon Sep 17 00:00:00 2001 From: "jian.feng" Date: Fri, 21 Oct 2022 00:07:20 +0800 Subject: [PATCH] [HUDI-4741] add comment --- .../src/main/java/org/apache/hudi/sink/meta/CkpMessage.java | 1 + 1 file changed, 1 insertion(+) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMessage.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMessage.java index 54210aa55e22b..d2ec3b95c7004 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMessage.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMessage.java @@ -106,6 +106,7 @@ public enum State { // An instant can be aborted then be reused again, so it has lower priority // than COMPLETED ABORTED, + // An instant can be reused from a partial recover (hence region restart) PARTIAL_RECOVER, // Committed instant COMPLETED