fix

924060929 · Jun 19, 2024 · 6c8081e · 6c8081e
1 parent 5c8c08a
commit 6c8081e
Showing 1 changed file with 3 additions and 3 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
@@ -57,7 +57,7 @@ protected List<AssignedJob> insideMachineParallelization(
             Map<Worker, UninstancedScanSource> workerToScanRanges,
             ListMultimap<ExchangeNode, AssignedJob> inputJobs) {
 
-        boolean useShareScan = useShareScan(workerToScanRanges);
+        boolean useLocalShuffleToAddParallel = useLocalShuffleToAddParallel(workerToScanRanges);
         int instanceIndexInFragment = 0;
         int shareScanIndex = 0;
         List<AssignedJob> instances = Lists.newArrayList();
@@ -79,7 +79,7 @@ protected List<AssignedJob> insideMachineParallelization(
             int instanceNum = degreeOfParallelism(scanSourceMaxParallel);
 
             List<ScanSource> instanceToScanRanges;
-            if (useShareScan) {
+            if (useLocalShuffleToAddParallel) {
                 // only generate one instance to scan all data, in this step
                 instanceToScanRanges = scanSource.parallelize(
                         scanNodes, 1
@@ -126,7 +126,7 @@ protected List<AssignedJob> insideMachineParallelization(
         return instances;
     }
 
-    protected boolean useShareScan(Map<Worker, UninstancedScanSource> workerToScanRanges) {
+    protected boolean useLocalShuffleToAddParallel(Map<Worker, UninstancedScanSource> workerToScanRanges) {
         if (ConnectContext.get() != null && ConnectContext.get().getSessionVariable().isForceToLocalShuffle()) {
             return true;
         }