opt

924060929 · Nov 28, 2024 · 7e13881 · 7e13881
1 parent 51ad321
commit 7e13881
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/...java/org/apache/doris/nereids/trees/plans/distribute/worker/job/UnassignedShuffleJob.java b/...java/org/apache/doris/nereids/trees/plans/distribute/worker/job/UnassignedShuffleJob.java
@@ -90,11 +90,6 @@ protected int degreeOfParallelism() {
         }
 
         // TODO: check nested loop join do right outer / semi / anti join
-        PlanNode leftMostNode = findLeftmostNode(fragment.getPlanRoot()).second;
-        // when we use nested loop join do right outer / semi / anti join, the instance must be 1.
-        if (leftMostNode.getNumInstances() == 1) {
-            expectInstanceNum = 1;
-        }
         return expectInstanceNum;
     }
 

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
@@ -1815,8 +1815,9 @@ protected void computeFragmentHosts() throws Exception {
                 if (ConnectContext.get() != null && ConnectContext.get().getSessionVariable() != null) {
                     exchangeInstances = ConnectContext.get().getSessionVariable().getExchangeInstanceParallel();
                 }
+                boolean isNereids = context != null && context.getState().isNereids();
                 // when we use nested loop join do right outer / semi / anti join, the instance must be 1.
-                if (leftMostNode.getNumInstances() == 1) {
+                if (!isNereids && leftMostNode.getNumInstances() == 1) {
                     exchangeInstances = 1;
                 }
                 // Using serial source means a serial source operator will be used in this fragment (e.g. data will be