[doris] 13/15: [fix](fe)fix bug if left table is empty and there are multiple right tables need do bucket shuffle to left side (#19169)

[morningman]

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

morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git

commit a97d1168d510b929ad9522ffe47331bf0f7b7eca
Author: starocean999 <40539150+starocean...@users.noreply.github.com>
AuthorDate: Fri Apr 28 15:06:38 2023 +0800

    [fix](fe)fix bug if left table is empty and there are multiple right tables 
need do bucket shuffle to left side (#19169)
    
    * [fix](fe)fix bug if left table is empty and there are multiple right 
tables need do bucket shuffle to left side
    
    * fix bug
    
    * fix test cases
---
 fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java | 3 ++-
 fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java        | 4 ++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java 
b/fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java
index 12725fbd1f..eae4c6e215 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java
@@ -868,7 +868,8 @@ public class StmtRewriter {
                     }
                 }
             } else {
-                joinOp = JoinOperator.LEFT_ANTI_JOIN;
+                joinOp = expr instanceof InPredicate ? 
JoinOperator.NULL_AWARE_LEFT_ANTI_JOIN
+                        : JoinOperator.LEFT_ANTI_JOIN;
             }
         }
 
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 31a392e3bf..d76677ac8d 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
@@ -1046,8 +1046,8 @@ public class Coordinator {
 
                 // when left table is empty, it's bucketset is empty.
                 // set right table destination address to the address of left 
table
-                if (destParams.instanceExecParams.size() == 1
-                        && 
destParams.instanceExecParams.get(0).bucketSeqSet.isEmpty()) {
+                if (destParams.instanceExecParams.size() == 1 && (bucketNum == 0
+                        || 
destParams.instanceExecParams.get(0).bucketSeqSet.isEmpty())) {
                     bucketNum = 1;
                     destParams.instanceExecParams.get(0).bucketSeqSet.add(0);
                 }


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