From 3c2e8b0ecfe786445dfab729bff1115f56f3c8b7 Mon Sep 17 00:00:00 2001 From: morrySnow <101034200+morrySnow@users.noreply.github.com> Date: Mon, 11 Dec 2023 14:58:42 +0800 Subject: [PATCH] [fix](Nereids) rewrite cte children check wrong map for consumer (#28220) --- .../apache/doris/nereids/rules/rewrite/RewriteCteChildren.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/RewriteCteChildren.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/RewriteCteChildren.java index 3318f9990d..72a4603fad 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/RewriteCteChildren.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/RewriteCteChildren.java @@ -78,7 +78,7 @@ public class RewriteCteChildren extends DefaultPlanRewriter imp CascadesContext cascadesContext) { LogicalPlan outer; if (cascadesContext.getStatementContext().getRewrittenCteConsumer().containsKey(cteAnchor.getCteId())) { - outer = cascadesContext.getStatementContext().getRewrittenCteProducer().get(cteAnchor.getCteId()); + outer = cascadesContext.getStatementContext().getRewrittenCteConsumer().get(cteAnchor.getCteId()); } else { CascadesContext outerCascadesCtx = CascadesContext.newSubtreeContext( Optional.empty(), cascadesContext, cteAnchor.child(1),