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();
}
}