(fluss) branch main updated: [lake/iceberg] only enable column stats when scan filter exists (#2842)

[yuxia]

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

yuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new a89311f4d [lake/iceberg] only enable column stats when scan filter 
exists (#2842)
a89311f4d is described below

commit a89311f4d1816d085fa46bc6fc5b32840c829d46
Author: Junfan Zhang <zus...@apache.org>
AuthorDate: Thu Mar 12 10:23:13 2026 +0800

    [lake/iceberg] only enable column stats when scan filter exists (#2842)
    
    Co-authored-by: Junfan Zhang <zhangjun...@qiyi.com>
---
 .../org/apache/fluss/lake/iceberg/source/IcebergSplitPlanner.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/source/IcebergSplitPlanner.java
 
b/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/source/IcebergSplitPlanner.java
index 4376108ba..2c308088c 100644
--- 
a/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/source/IcebergSplitPlanner.java
+++ 
b/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/source/IcebergSplitPlanner.java
@@ -68,9 +68,9 @@ public class IcebergSplitPlanner implements 
Planner<IcebergSplit> {
         Table table = catalog.loadTable(toIceberg(tablePath));
         Function<FileScanTask, List<String>> partitionExtract = 
createPartitionExtractor(table);
         Function<FileScanTask, Integer> bucketExtractor = 
createBucketExtractor(table);
-        TableScan tableScan = 
table.newScan().useSnapshot(snapshotId).includeColumnStats();
+        TableScan tableScan = table.newScan().useSnapshot(snapshotId);
         if (filter != null) {
-            tableScan = tableScan.filter(filter);
+            tableScan = tableScan.includeColumnStats().filter(filter);
         }
         try (CloseableIterable<FileScanTask> tasks = tableScan.planFiles()) {
             tasks.forEach(