(hudi) branch master updated: [MINOR] Fix the log offset for merged write stat (#11806)

[danny0405]

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

danny0405 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 4b5c22339c7 [MINOR] Fix the log offset for merged write stat (#11806)
4b5c22339c7 is described below

commit 4b5c22339c7e412828b61469d8a037a6d73d2aa2
Author: Danny Chan <yuzhao....@gmail.com>
AuthorDate: Wed Aug 21 11:19:24 2024 +0800

    [MINOR] Fix the log offset for merged write stat (#11806)
---
 .../src/main/java/org/apache/hudi/util/WriteStatMerger.java             | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/util/WriteStatMerger.java
 
b/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/util/WriteStatMerger.java
index ded4d124ab5..07e08b19b58 100644
--- 
a/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/util/WriteStatMerger.java
+++ 
b/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/util/WriteStatMerger.java
@@ -45,7 +45,7 @@ public class WriteStatMerger {
     HoodieDeltaWriteStat merged = new HoodieDeltaWriteStat();
     mergeWriteStat(merged, stat1, stat2);
     merged.setLogVersion(stat2.getLogVersion());
-    merged.setLogOffset(stat2.getLogOffset());
+    merged.setLogOffset(maxLong(stat1.getLogOffset(), stat2.getLogOffset()));
     merged.setBaseFile(stat2.getBaseFile());
     // log files
     List<String> mergedLogFiles = new ArrayList<>(stat1.getLogFiles());