From 99c8e47518b3ceb078fa410b89c244c76f2b7938 Mon Sep 17 00:00:00 2001 From: minghong Date: Wed, 10 Jan 2024 18:36:27 +0800 Subject: [PATCH] [fix](nereids) fix regression case "nereids_p0/runtimefilter" (#29776) --- .../doris/nereids/processor/post/RuntimeFilterGenerator.java | 1 + .../suites/nereids_p0/runtime_filter/runtime_filter.groovy | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) 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);