This is an automated email from the ASF dual-hosted git repository.

gabriellee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new ac13353c533 [fix](shared scan) Disable shared scan if Nereids is 
disabled (#39589)
ac13353c533 is described below

commit ac13353c53367c9289efe44f8679b614df1a13ab
Author: Gabriel <gabrielleeb...@gmail.com>
AuthorDate: Tue Aug 20 14:12:22 2024 +0800

    [fix](shared scan) Disable shared scan if Nereids is disabled (#39589)
---
 fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 4 ++--
 1 file changed, 2 insertions(+), 2 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 fe954747c2b..c52bcebc0d0 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
@@ -1907,7 +1907,7 @@ public class Coordinator implements CoordInterface {
                                 leftMostNode.getNumInstances());
                         boolean forceToLocalShuffle = context != null
                                 && 
context.getSessionVariable().isForceToLocalShuffle()
-                                && !fragment.hasNullAwareLeftAntiJoin();
+                                && !fragment.hasNullAwareLeftAntiJoin() && 
useNereids;
                         boolean ignoreStorageDataDistribution = 
forceToLocalShuffle || (node.isPresent()
                                 && 
node.get().ignoreStorageDataDistribution(context, addressToBackendID.size())
                                 && useNereids);
@@ -2735,7 +2735,7 @@ public class Coordinator implements CoordInterface {
          * 2. Use Nereids planner.
          */
         boolean forceToLocalShuffle = context != null
-                && context.getSessionVariable().isForceToLocalShuffle() && 
!hasNullAwareLeftAntiJoin;
+                && context.getSessionVariable().isForceToLocalShuffle() && 
!hasNullAwareLeftAntiJoin && useNereids;
         boolean ignoreStorageDataDistribution = forceToLocalShuffle || 
(scanNodes.stream()
                 .allMatch(node -> node.ignoreStorageDataDistribution(context,
                         addressToBackendID.size()))


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to