save

924060929 · Jun 12, 2024 · fd33f28 · fd33f28
1 parent b05d490
commit fd33f28
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/AbstractUnassignedScanJob.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/AbstractUnassignedScanJob.java
@@ -56,7 +56,7 @@ protected abstract Map<Worker, UninstancedScanSource> multipleMachinesParalleliz
     protected List<AssignedJob> insideMachineParallelization(
             Map<Worker, UninstancedScanSource> workerToScanRanges) {
 
-        boolean useLocalShuffle = useShareScan(workerToScanRanges);
+        boolean useShareScan = useShareScan(workerToScanRanges);
         int instanceIndexInFragment = 0;
         int shareScanIndex = 0;
         List<AssignedJob> instances = Lists.newArrayList();
@@ -78,7 +78,7 @@ protected List<AssignedJob> insideMachineParallelization(
             int instanceNum = degreeOfParallelism(scanSourceMaxParallel);
 
             List<ScanSource> instanceToScanRanges;
-            if (useLocalShuffle) {
+            if (useShareScan) {
                 // only generate one instance to scan all data, in this step
                 instanceToScanRanges = scanSource.parallelize(
                         scanNodes, 1