share hash table

924060929 · Oct 9, 2024 · b3e619c · b3e619c
1 parent cee316d
commit b3e619c
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -92,7 +92,7 @@ protected List<AssignedJob> insideMachineParallelization(
             int instanceNum = degreeOfParallelism(scanSourceMaxParallel);
 
             List<ScanSource> instanceToScanRanges;
-            if (useLocalShuffleToAddParallel) {
+            if (useLocalShuffleToAddParallel && instanceNum > 1) {
                 // only generate one instance to scan all data, in this step
                 instanceToScanRanges = scanSource.parallelize(
                         scanNodes, 1