(paimon) branch master updated: [core] [fix] Fix row id push down, blob bunch check failed (#6553)

[junhao]

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

junhao 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 0ce5870557 [core] [fix] Fix row id push down, blob bunch check failed 
(#6553)
0ce5870557 is described below

commit 0ce5870557c028217389248a037b3b55aecb75c0
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Fri Nov 7 11:16:09 2025 +0800

    [core] [fix] Fix row id push down, blob bunch check failed (#6553)
---
 .../main/java/org/apache/paimon/operation/DataEvolutionSplitRead.java | 3 ++-
 .../test/java/org/apache/paimon/operation/DataEvolutionReadTest.java  | 4 ++++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/operation/DataEvolutionSplitRead.java
 
b/paimon-core/src/main/java/org/apache/paimon/operation/DataEvolutionSplitRead.java
index 47a247be48..366aadc41e 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/operation/DataEvolutionSplitRead.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/operation/DataEvolutionSplitRead.java
@@ -466,7 +466,8 @@ public class DataEvolutionSplitRead implements 
SplitRead<InternalRow> {
                 if (rowIdPushDown) {
                     if (firstRowId < expectedNextFirstRowId) {
                         if (file.maxSequenceNumber() > 
latestMaxSequenceNumber) {
-                            files.remove(files.size() - 1);
+                            DataFileMeta lastFile = files.remove(files.size() 
- 1);
+                            rowCount -= lastFile.rowCount();
                         } else {
                             return;
                         }
diff --git 
a/paimon-core/src/test/java/org/apache/paimon/operation/DataEvolutionReadTest.java
 
b/paimon-core/src/test/java/org/apache/paimon/operation/DataEvolutionReadTest.java
index 6b9dd29b59..452813d9d9 100644
--- 
a/paimon-core/src/test/java/org/apache/paimon/operation/DataEvolutionReadTest.java
+++ 
b/paimon-core/src/test/java/org/apache/paimon/operation/DataEvolutionReadTest.java
@@ -336,6 +336,10 @@ public class DataEvolutionReadTest {
         blobBunch.add(blobEntry1);
         blobBunch.add(blobEntry2);
         assertThat(blobBunch.files).containsExactlyInAnyOrder(blobEntry2);
+
+        BlobBunch finalBlobBunch2 = blobBunch;
+        DataFileMeta blobEntry3 = createBlobFile("blob2", 250, 100, 2);
+        assertThatCode(() -> 
finalBlobBunch2.add(blobEntry3)).doesNotThrowAnyException();
     }
 
     /** Creates a normal (non-blob) file for testing. */