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 da28b40b03..6442d06284 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 @@ -370,6 +370,7 @@ public class RuntimeFilterGenerator extends PlanPostProcessor { List hashJoinConjuncts = join.getHashJoinConjuncts().stream().collect(Collectors.toList()); for (int i = 0; i < hashJoinConjuncts.size(); i++) { + // BE do not support RF generated from NullSafeEqual, skip them if (hashJoinConjuncts.get(i) instanceof EqualTo) { EqualTo equalTo = ((EqualTo) JoinUtils.swapEqualToForChildrenOrder( (EqualTo) hashJoinConjuncts.get(i), join.left().getOutputSet())); diff --git a/regression-test/suites/nereids_p0/runtime_filter/runtime_filter.groovy b/regression-test/suites/nereids_p0/runtime_filter/runtime_filter.groovy index 905ac6dd87..17fac79427 100644 --- a/regression-test/suites/nereids_p0/runtime_filter/runtime_filter.groovy +++ b/regression-test/suites/nereids_p0/runtime_filter/runtime_filter.groovy @@ -38,7 +38,7 @@ suite("runtime_filter") { rf_dws_asset_domain_statistics_daily t1 INNER JOIN ( SELECT account_id, account_name - FROM dws_asset_domain_statistics_daily + FROM rf_dws_asset_domain_statistics_daily WHERE d_s = '2023-12-20' ) t2 ON (t1.account_id <=> t2.account_id);