You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2026/01/29 09:07:34 UTC

(paimon) branch master updated: [hotfix] Minor optimize performance in authedReader

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 5be974b3ba [hotfix] Minor optimize performance in authedReader
5be974b3ba is described below

commit 5be974b3ba2087a1925907276c13bac066746d22
Author: JingsongLi <ji...@gmail.com>
AuthorDate: Thu Jan 29 17:07:16 2026 +0800

    [hotfix] Minor optimize performance in authedReader
---
 .../java/org/apache/paimon/table/source/AbstractDataTableRead.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableRead.java b/paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableRead.java
index 691cf0f765..caf86b1754 100644
--- a/paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableRead.java
+++ b/paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableRead.java
@@ -31,6 +31,7 @@ import org.apache.paimon.utils.ProjectedRow;
 
 import java.io.IOException;
 import java.util.ArrayList;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Optional;
 import java.util.Set;
@@ -119,8 +120,9 @@ public abstract class AbstractDataTableRead implements InnerTableRead {
             Set<String> authFields = collectFieldNames(authPredicate);
             List<String> readFields = readType.getFieldNames();
             List<String> authAddNames = new ArrayList<>();
+            Set<String> readFieldSet = new HashSet<>(readFields);
             for (String field : tableType.getFieldNames()) {
-                if (authFields.contains(field) && !readFields.contains(field)) {
+                if (authFields.contains(field) && !readFieldSet.contains(field)) {
                     authAddNames.add(field);
                 }
             }