forbid rf pushdown through asof join

starocean999 · starocean999 · commit 4a11d64f9713 · 2026-03-04T17:25:20.000+08:00
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterPushDownVisitor.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterPushDownVisitor.java
@@ -245,6 +245,9 @@ public Boolean visitPhysicalHashJoin(PhysicalHashJoin<? extends Plan, ? extends
                 && !join.getOutputSet().containsAll(ctx.probeExpr.getInputSlots())) {
             return false;
         }
+        if (join.getJoinType().isAsofJoin()) {
+            return false;
+        }
         boolean pushed = false;
 
         if (ctx.builderNode instanceof PhysicalHashJoin) {

Original file line number	Diff line number	Diff line change
`@@ -245,6 +245,9 @@ public Boolean visitPhysicalHashJoin(PhysicalHashJoin<? extends Plan, ? extends`
`245`	`245`	`&& !join.getOutputSet().containsAll(ctx.probeExpr.getInputSlots())) {`
`246`	`246`	`return false;`
`247`	`247`	`}`
	`248`	`+ if (join.getJoinType().isAsofJoin()) {`
	`249`	`+ return false;`
	`250`	`+ }`
`248`	`251`	`boolean pushed = false;`
`249`	`252`
`250`	`253`	`if (ctx.builderNode instanceof PhysicalHashJoin) {`