fix

924060929 · Jun 19, 2024 · b417ba1 · b417ba1
1 parent b44a683
commit b417ba1
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 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
@@ -101,7 +101,7 @@ protected List<AssignedJob> insideMachineParallelization(
                 for (int i = 0; i < instanceNum; i++) {
                     // one scan range generate multiple instances,
                     // different instances reference the same scan source
-                    ShareScanAssignedJob instance = new ShareScanAssignedJob(
+                    LocalShuffleAssignedJob instance = new LocalShuffleAssignedJob(
                             instanceIndexInFragment++, shareScanIndex, this, worker, shareScanSource);
                     instances.add(instance);
                 }

diff --git a/...eids/worker/job/ShareScanAssignedJob.java → ...s/worker/job/LocalShuffleAssignedJob.java b/...eids/worker/job/ShareScanAssignedJob.java → ...s/worker/job/LocalShuffleAssignedJob.java
@@ -23,11 +23,11 @@
 
 import java.util.Map;
 
-/** ShareScanAssignedJob */
-public class ShareScanAssignedJob extends StaticAssignedJob {
+/** LocalShuffleAssignedJob */
+public class LocalShuffleAssignedJob extends StaticAssignedJob {
     public final int shareScanId;
 
-    public ShareScanAssignedJob(
+    public LocalShuffleAssignedJob(
             int indexInUnassignedJob, int shareScanId,
             UnassignedJob unassignedJob,
             Worker worker, ScanSource scanSource) {

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -51,7 +51,7 @@
 import org.apache.doris.nereids.worker.job.DefaultScanSource;
 import org.apache.doris.nereids.worker.job.ScanRanges;
 import org.apache.doris.nereids.worker.job.ScanSource;
-import org.apache.doris.nereids.worker.job.ShareScanAssignedJob;
+import org.apache.doris.nereids.worker.job.LocalShuffleAssignedJob;
 import org.apache.doris.nereids.worker.job.UnassignedJob;
 import org.apache.doris.planner.DataPartition;
 import org.apache.doris.planner.DataSink;
@@ -1789,7 +1789,7 @@ private void computeFragmentHosts() throws Exception {
                 List<AssignedJob> instanceJobs = ((PipelineDistributedPlan) distributedPlan).getInstanceJobs();
                 boolean isShareScan = false;
                 for (AssignedJob instanceJob : instanceJobs) {
-                    if (instanceJob instanceof ShareScanAssignedJob) {
+                    if (instanceJob instanceof LocalShuffleAssignedJob) {
                         isShareScan = true;
                         break;
                     }