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 f323c6a2af [hotfix] Correct mergedRowCount in QueryAuthSplit
f323c6a2af is described below

commit f323c6a2af963523f2103dca11fea5020be385d6
Author: JingsongLi <[email protected]>
AuthorDate: Thu Jan 22 11:21:52 2026 +0800

    [hotfix] Correct mergedRowCount in QueryAuthSplit
---
 .../src/main/java/org/apache/paimon/table/source/QueryAuthSplit.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/table/source/QueryAuthSplit.java 
b/paimon-core/src/main/java/org/apache/paimon/table/source/QueryAuthSplit.java
index 9b9042b7e2..2b51daa880 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/table/source/QueryAuthSplit.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/table/source/QueryAuthSplit.java
@@ -22,6 +22,7 @@ import org.apache.paimon.catalog.TableQueryAuthResult;
 
 import javax.annotation.Nullable;
 
+import java.util.List;
 import java.util.OptionalLong;
 
 /** A wrapper class for {@link Split} that adds query authorization 
information. */
@@ -53,6 +54,10 @@ public class QueryAuthSplit implements Split {
 
     @Override
     public OptionalLong mergedRowCount() {
+        List<String> filter = authResult.filter();
+        if (filter != null && !filter.isEmpty()) {
+            return OptionalLong.empty();
+        }
         return split.mergedRowCount();
     }
 }

Reply via email to