This is an automated email from the ASF dual-hosted git repository. vinoyang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push: new 8b0a502 [HUDI-2014] Support flink hive sync in batch mode (#3081) 8b0a502 is described below commit 8b0a502c4fd5352863009030a32e219bbf822a6c Author: swuferhong <337361...@qq.com> AuthorDate: Wed Jun 16 14:29:16 2021 +0800 [HUDI-2014] Support flink hive sync in batch mode (#3081) --- .../main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java b/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java index 4963d31..da771e0 100644 --- a/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java +++ b/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java @@ -171,6 +171,9 @@ public class StreamWriteOperatorCoordinator if (executor != null) { executor.close(); } + // sync Hive if is enabled in batch mode. + syncHiveIfEnabled(); + this.eventBuffer = null; }