avoid generate Runtime filter whose target is not a base table column

apache · Mar 6, 2025 · 2007ef9 · 2007ef9
1 parent 7b2899a
commit 2007ef9
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterContext.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterContext.java
@@ -279,6 +279,10 @@ public Pair<PhysicalRelation, Slot> aliasTransferMapPut(NamedExpression slot, Pa
         return aliasTransferMap.put(slot, pair);
     }
 
+    public void aliasTransferMapRemove(NamedExpression slot) {
+        aliasTransferMap.remove(slot);
+    }
+
     public boolean aliasTransferMapContains(NamedExpression slot) {
         return aliasTransferMap.containsKey(slot);
     }

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
@@ -37,6 +37,7 @@
 import org.apache.doris.nereids.trees.expressions.Slot;
 import org.apache.doris.nereids.trees.expressions.SlotReference;
 import org.apache.doris.nereids.trees.expressions.functions.scalar.BitmapContains;
+import org.apache.doris.nereids.trees.expressions.literal.Literal;
 import org.apache.doris.nereids.trees.plans.AbstractPlan;
 import org.apache.doris.nereids.trees.plans.JoinType;
 import org.apache.doris.nereids.trees.plans.Plan;
@@ -440,6 +441,21 @@ public PhysicalPlan visitPhysicalProject(PhysicalProject<? extends Plan> project
             if (expression.children().isEmpty()) {
                 continue;
             }
+            /*
+             * join(#5=#6)
+             *   -->project(null as #5)
+             *       --> any
+             *   -->project(#6)
+             *       --->scan(T[#5, #6])
+             *
+             * both left tree and right tree contain exprId=5.
+             * remove #5 from alias map to avoid generate wrong rf
+             */
+            if (expression instanceof Alias && expression.child(0) instanceof Literal) {
+                Alias alias = (Alias) expression;
+                ctx.aliasTransferMapRemove(alias.toSlot());
+                continue;
+            }
             Expression expr = ExpressionUtils.getSingleNumericSlotOrExpressionCoveredByCast(expression.child(0));
             if (expr instanceof NamedExpression
                     && ctx.aliasTransferMapContains((NamedExpression) expr)) {