This is an automated email from the ASF dual-hosted git repository.
englefly pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 561e35171ad [fix](nereids) fix regression case
"nereids_p0/runtimefilter" (#29776)
561e35171ad is described below
commit 561e35171ad5f1b15d1e2522f0564929a79a6d88
Author: minghong <[email protected]>
AuthorDate: Wed Jan 10 18:36:27 2024 +0800
[fix](nereids) fix regression case "nereids_p0/runtimefilter" (#29776)
---
.../org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java | 1 +
regression-test/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 da28b40b038..6442d062840 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<Expression> 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 905ac6dd87b..17fac79427e 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);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
