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 index 0a89d6f5afb0df..dcea98a491428e 100644 --- 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 @@ -2048,8 +2048,8 @@ private void computeFragmentHosts() throws Exception { instanceParam.perNodeSharedScans.put(planNodeId, sharedScan); params.instanceExecParams.add(instanceParam); } - params.ignoreDataDistribution = sharedScan; - params.parallelTasksNum = sharedScan ? 1 : params.instanceExecParams.size(); + params.ignoreDataDistribution = sharedScan && enablePipelineXEngine; + params.parallelTasksNum = params.ignoreDataDistribution ? 1 : params.instanceExecParams.size(); } } } @@ -2926,8 +2926,8 @@ private void assignScanRanges(PlanFragmentId fragmentId, int parallelExecInstanc } } } - params.parallelTasksNum = ignoreStorageDataDistribution ? 1 : params.instanceExecParams.size(); - params.ignoreDataDistribution = ignoreStorageDataDistribution; + params.ignoreDataDistribution = ignoreStorageDataDistribution && enablePipelineXEngine; + params.parallelTasksNum = params.ignoreDataDistribution ? 1 : params.instanceExecParams.size(); } private final Map fragmentIdTobucketSeqToScanRangeMap = Maps.newHashMap();