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