diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/SingleNodePlanner.java b/fe/fe-core/src/main/java/org/apache/doris/planner/SingleNodePlanner.java index ac3450534fe511..8a4bc83e2d6a76 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/SingleNodePlanner.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/SingleNodePlanner.java @@ -73,7 +73,6 @@ import java.util.Map; import java.util.HashSet; import java.util.Set; -import java.util.UUID; /** * Constructs a non-executable single-node plan from an analyzed parse tree. @@ -86,7 +85,7 @@ public class SingleNodePlanner { private final PlannerContext ctx_; private final ArrayList scanNodes = Lists.newArrayList(); - private Map> selectStmtToScanNodes = Maps.newHashMap(); + private Map> selectStmtToScanNodes = Maps.newHashMap(); public SingleNodePlanner(PlannerContext ctx) { ctx_ = ctx; @@ -778,7 +777,7 @@ public boolean selectMaterializedView(QueryStmt queryStmt, Analyzer analyzer) ((InlineViewRef) tableRef).getAnalyzer()); } } - List scanNodeList = selectStmtToScanNodes.get(selectStmt.getId()); + List scanNodeList = selectStmtToScanNodes.get(selectStmt.getAnalyzer()); if (scanNodeList == null) { return selectFailed; } @@ -1455,7 +1454,7 @@ private PlanNode createScanNode(Analyzer analyzer, TableRef tblRef, SelectStmt s analyzer.materializeSlots(scanNode.getConjuncts()); scanNodes.add(scanNode); - List scanNodeList = selectStmtToScanNodes.computeIfAbsent(selectStmt.getId(), k -> Lists.newArrayList()); + List scanNodeList = selectStmtToScanNodes.computeIfAbsent(selectStmt.getAnalyzer(), k -> Lists.newArrayList()); scanNodeList.add(scanNode); return scanNode; }