(hudi) branch master updated: [HUDI-8862] Fix inconsistent instant when sync hive in StreamWriteOperatorCoordinator (#12632)

[zhangyue19921010]

This is an automated email from the ASF dual-hosted git repository.

zhangyue19921010 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 413aa1bd931 [HUDI-8862] Fix inconsistent instant when sync hive in 
StreamWriteOperatorCoordinator (#12632)
413aa1bd931 is described below

commit 413aa1bd93115dfb314868c4fdf161833b5ed4c3
Author: fhan <aaron.han.1...@gmail.com>
AuthorDate: Wed Jan 15 12:45:41 2025 +0800

    [HUDI-8862] Fix inconsistent instant when sync hive in 
StreamWriteOperatorCoordinator (#12632)
    
    * [HUDI-8862]fix inconsistent instant when sync hive in 
StreamWriteOperatorCoordinator
    
    * adjust impl
    
    ---------
    
    Co-authored-by: fhan <yfhan...@jd.com>
---
 .../java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
index fbb2a5ff391..64b580a20ad 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
@@ -265,10 +265,10 @@ public class StreamWriteOperatorCoordinator
           scheduleTableServices(committed);
 
           if (committed) {
-            // start new instant.
-            startInstant();
             // sync Hive if is enabled
             syncHiveAsync();
+            // start new instant.
+            startInstant();
           }
         }, "commits the instant %s", this.instant
     );