From 6c8081ede6435349b35e200524e85decc7110504 Mon Sep 17 00:00:00 2001
From: 924060929 <924060929@qq.com>
Date: Wed, 19 Jun 2024 16:21:16 +0800
Subject: [PATCH] fix

---
 .../doris/nereids/worker/job/AbstractUnassignedScanJob.java | 6 +++---
 1 file changed, 3 insertions(+), 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
index b8e84778be28d4f..2597144140127bf 100644
--- 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;
         }