From 7b043116c0331376a7b0fac602157a8c39c77874 Mon Sep 17 00:00:00 2001 From: minghong Date: Fri, 3 Jan 2025 22:28:36 +0800 Subject: [PATCH] pick #46406 --- .../doris/nereids/processor/post/RuntimeFilterGenerator.java | 5 ----- 1 file changed, 5 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 index 1c6f56518947ee..57c322d030f8fe 100644 --- 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 @@ -274,11 +274,6 @@ public PhysicalPlan visitPhysicalHashJoin(PhysicalHashJoin pair = ctx.getAliasTransferMap().get(equalTo.right()); - // CteConsumer is not allowed to generate RF in order to avoid RF cycle. - if (pair == null) { - continue; - } if (equalTo.left().getInputSlots().size() == 1) { RuntimeFilterPushDownVisitor.PushDownContext pushDownContext = RuntimeFilterPushDownVisitor.PushDownContext.createPushDownContextForHashJoin(