[hudi] branch master updated: [HUDI-2014] Support flink hive sync in batch mode (#3081)

[vinoyang]

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;
   }