fix bug

starocean999 · Feb 5, 2024 · e5169c8 · e5169c8
1 parent e095e70
commit e5169c8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java
@@ -436,10 +436,9 @@ public PhysicalPlan visitPhysicalNestedLoopJoin(PhysicalNestedLoopJoin<? extends
         join.right().accept(this, context);
         join.left().accept(this, context);
 
-        if (RuntimeFilterGenerator.DENIED_JOIN_TYPES.contains(join.getJoinType())
-                || JoinUtils.isNullAwareMarkJoin(join)) {
-            join.right().getOutput().forEach(
-                    slot -> context.getRuntimeFilterContext().aliasTransferMapRemove(slot));
+        if (RuntimeFilterGenerator.DENIED_JOIN_TYPES.contains(join.getJoinType()) || join.isMarkJoin()) {
+            join.right().getOutput().forEach(slot ->
+                    context.getRuntimeFilterContext().aliasTransferMapRemove(slot));
             return join;
         }
         RuntimeFilterContext ctx = context.getRuntimeFilterContext();

diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/join/JoinCommute.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/join/JoinCommute.java
@@ -61,6 +61,7 @@ public Rule build() {
                 .whenNot(LogicalJoin::hasDistributeHint)
                 .whenNot(join -> joinOrderMatchBitmapRuntimeFilterOrder(join))
                 .whenNot(join -> JoinUtils.isNullAwareMarkJoin(join))
+                .whenNot(join -> join.isMarkJoin() && join.getHashJoinConjuncts().isEmpty())
                 .then(join -> {
                     LogicalJoin<Plan, Plan> newJoin = join.withTypeChildren(join.getJoinType().swap(),
                             join.right(), join.left());