You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by fo...@apache.org on 2023/01/04 03:32:41 UTC
[hudi] 31/45: [HUDI-5095] Flink: Stores a special watermark(flag) to identify the current progress of writing data
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 <fo...@apache.com>
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.
*/