This is an automated email from the ASF dual-hosted git repository. forwardxu pushed a commit to branch release-0.12.1 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit c070e0963a08264ace559333baa5b96780ddc8df Author: XuQianJin-Stars <[email protected]> AuthorDate: Tue Nov 29 23:33:22 2022 +0800 [HUDI-5095] Flink: Stores a special watermark(flag) to identify the current progress of writing data --- .../java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java index 4a3674ec29..f4acc2e83a 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java @@ -511,6 +511,7 @@ public class StreamWriteOperatorCoordinator } setMinEventTime(); doCommit(instant, writeResults); + resetMinEventTime(); return true; } @@ -532,6 +533,10 @@ public class StreamWriteOperatorCoordinator } } + public void resetMinEventTime() { + this.minEventTime = Long.MAX_VALUE; + } + /** * Performs the actual commit action. */
