fix

924060929 · Jan 3, 2025 · 977d957 · 977d957
1 parent 4b6490f
commit 977d957
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...org/apache/doris/nereids/trees/plans/distribute/worker/job/AbstractUnassignedScanJob.java b/...org/apache/doris/nereids/trees/plans/distribute/worker/job/AbstractUnassignedScanJob.java
@@ -84,7 +84,7 @@ protected List<AssignedJob> insideMachineParallelization(
             ScanSource scanSource = entry.getValue().scanSource;
 
             // usually, its tablets num, or buckets num
-            int scanSourceMaxParallel = Math.max(scanSource.maxParallel(scanNodes), 1);
+            int scanSourceMaxParallel = scanSource.maxParallel(scanNodes);
 
             // now we should compute how many instances to process the data,
             // for example: two instances
@@ -180,7 +180,7 @@ protected int degreeOfParallelism(int maxParallel, boolean useLocalShuffleToAddP
         }
 
         // the scan instance num should not larger than the tablets num
-        return maxParallel;
+        return Math.min(maxParallel, Math.max(fragment.getParallelExecNum(), 1));
     }
 
     protected List<AssignedJob> fillUpSingleEmptyInstance(DistributedPlanWorkerManager workerManager) {