(paimon) branch master updated: [core] Fix merge adjacent files in DataEvolutionCompactCoordinator

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 305fe02019 [core] Fix merge adjacent files in 
DataEvolutionCompactCoordinator
305fe02019 is described below

commit 305fe02019fe1944eb44e21243667e592cc9b371
Author: JingsongLi <jingsongl...@gmail.com>
AuthorDate: Thu Feb 12 12:57:27 2026 +0800

    [core] Fix merge adjacent files in DataEvolutionCompactCoordinator
---
 .../append/dataevolution/DataEvolutionCompactCoordinator.java      | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/append/dataevolution/DataEvolutionCompactCoordinator.java
 
b/paimon-core/src/main/java/org/apache/paimon/append/dataevolution/DataEvolutionCompactCoordinator.java
index 610eab6a6e..c69932ed15 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/append/dataevolution/DataEvolutionCompactCoordinator.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/append/dataevolution/DataEvolutionCompactCoordinator.java
@@ -162,7 +162,12 @@ public class DataEvolutionCompactCoordinator {
                 BinaryRow partition = partitionFiles.getKey();
                 List<DataFileMeta> files = partitionFiles.getValue();
                 RangeHelper<DataFileMeta> rangeHelper =
-                        new RangeHelper<>(DataFileMeta::nonNullRowIdRange);
+                        new RangeHelper<>(
+                                f ->
+                                        new Range(
+                                                f.nonNullFirstRowId(),
+                                                // merge adjacent files
+                                                f.nonNullFirstRowId() + 
f.rowCount()));
 
                 List<List<DataFileMeta>> ranges = 
rangeHelper.mergeOverlappingRanges(files);