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 6d07a00690729c..a701657e51cf6c 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
@@ -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