fix

apache · Sep 23, 2024 · 1e4d795 · 1e4d795
1 parent 5b9388d
commit 1e4d795
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/source/IcebergScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/source/IcebergScanNode.java
@@ -88,6 +88,7 @@ public class IcebergScanNode extends FileQueryScanNode {
     private Table icebergTable;
     private List<String> pushdownIcebergPredicates = Lists.newArrayList();
     private boolean pushDownCount = false;
+    private static final long COUNT_WITH_PARALLEL_SPLITS = 10000;
 
     /**
      * External file scan node for Query iceberg table
@@ -269,7 +270,7 @@ private List<Split> doGetSplits() throws UserException {
             if (countFromSnapshot >= 0) {
                 pushDownCount = true;
                 List<Split> pushDownCountSplits;
-                if (countFromSnapshot > 10000) {
+                if (countFromSnapshot > COUNT_WITH_PARALLEL_SPLITS) {
                     int parallelNum = ConnectContext.get().getSessionVariable().getParallelExecInstanceNum();
                     pushDownCountSplits = splits.subList(0, Math.min(splits.size(), parallelNum));
                 } else {