lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2014] Support flink hive sync in batch mode (#3081)

Browse Source
This commit is contained in:
swuferhong
2021-06-16 14:29:16 +08:00
committed by GitHub
parent 61efc6af79
commit 8b0a502c4f
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
View File

@@ -171,6 +171,9 @@ public class StreamWriteOperatorCoordinator
if (executor != null) { if (executor != null) {
executor.close(); executor.close();
} }
// sync Hive if is enabled in batch mode.
syncHiveIfEnabled();
this.eventBuffer = null; this.eventBuffer = null;
} }