From 8b0a502c4fd5352863009030a32e219bbf822a6c Mon Sep 17 00:00:00 2001
From: swuferhong <337361684@qq.com>
Date: Wed, 16 Jun 2021 14:29:16 +0800
Subject: [PATCH] [HUDI-2014] Support flink hive sync in batch mode (#3081)

---
 .../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 4963d31e2..da771e035 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;
   }