[fix](nereids) null-safe-eq runtime filter denies outer join #32927

apache · Mar 31, 2024 · e0927e7 · e0927e7
1 parent 63cd37b
commit e0927e7
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHashJoin.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHashJoin.java
@@ -211,6 +211,12 @@ public boolean pushDownRuntimeFilter(CascadesContext context, IdGenerator<Runtim
                 if (builderJoin == this) {
                     return false;
                 }
+                EqualPredicate equal = (EqualPredicate) builderNode.getHashJoinConjuncts().get(exprOrder);
+                if (equal instanceof NullSafeEqual) {
+                    if (this.joinType.isOuterJoin()) {
+                        return false;
+                    }
+                }
             }
         }
         EqualPredicate equal = (EqualPredicate) builderNode.getHashJoinConjuncts().get(exprOrder);