From cb61a0727f1b9a4c1da51b24bd81853fc55c0923 Mon Sep 17 00:00:00 2001
From: Gabriel <gabrielleebuaa@gmail.com>
Date: Fri, 22 Dec 2023 15:13:14 +0800
Subject: [PATCH] [bug](sharedscan) Fix shared scan bug (#28841)

---
 .../src/main/java/org/apache/doris/qe/Coordinator.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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 d448091676f9fa..9564461d756b11 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
@@ -2066,8 +2066,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();
                     }
                 }
             }
@@ -2944,8 +2944,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<PlanFragmentId, BucketSeqToScanRange> fragmentIdTobucketSeqToScanRangeMap = Maps.newHashMap();