diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/DefaultExpressionRewriter.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/DefaultExpressionRewriter.java index fd25f9368e..9e86ebb215 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/DefaultExpressionRewriter.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/DefaultExpressionRewriter.java @@ -18,6 +18,7 @@ package org.apache.doris.nereids.trees.expressions.visitor; import org.apache.doris.nereids.trees.expressions.Expression; +import org.apache.doris.nereids.trees.expressions.WhenClause; import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableList.Builder; @@ -33,6 +34,12 @@ public abstract class DefaultExpressionRewriter extends ExpressionVisitor E rewriteChildren( ExpressionVisitor rewriter, E expr, C context) { diff --git a/regression-test/suites/nereids_syntax_p0/join.groovy b/regression-test/suites/nereids_syntax_p0/join.groovy index 63382c3ed4..65eddd01d7 100644 --- a/regression-test/suites/nereids_syntax_p0/join.groovy +++ b/regression-test/suites/nereids_syntax_p0/join.groovy @@ -271,4 +271,42 @@ suite("join") { where ref_2.`id` is not NULL """ + + multi_sql """ + drop table if exists table_test1; + drop table if exists table_test2; + + CREATE TABLE table_test1 ( + id VARCHAR(20) NULL, + long1 BIGINT NULL, + long2 BIGINT NULL, + ) ENGINE=OLAP + DUPLICATE KEY(id) + COMMENT 'olap' + DISTRIBUTED BY HASH(id) BUCKETS AUTO + PROPERTIES ( + "replication_allocation" = "tag.location.default: 1" + ); + + CREATE TABLE table_test2 ( + id VARCHAR(20) NULL, + re_long_4 BIGINT NULL, + ) ENGINE=OLAP + DUPLICATE KEY(id) + COMMENT 'olap' + DISTRIBUTED BY HASH(id) BUCKETS AUTO + PROPERTIES ( + "replication_allocation" = "tag.location.default: 1" + ); + + SELECT 1 + from table_test1 b + WHERE ( + CASE + WHEN b.long2=(SELECT re_long_4 FROM table_test2 limit 1) THEN (select long1 from table_test1 limit 1 ) + WHEN b.long2=(SELECT re_long_4 FROM table_test2 limit 1) THEN (select long1 from table_test1 limit 1) + ELSE b.long2 + END + )>0; + """ }