From ff4f005bab3b0264a0fe71131df09d06793ca8e9 Mon Sep 17 00:00:00 2001 From: yangzhg Date: Tue, 13 Oct 2020 20:12:01 +0800 Subject: [PATCH] fix join error when the table has enbale batch delete --- .../java/org/apache/doris/planner/SingleNodePlanner.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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 69ae7fc07ddba0..ae29c3af3968c4 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 @@ -1366,8 +1366,10 @@ private PlanNode createScanNode(Analyzer analyzer, TableRef tblRef, SelectStmt s case OLAP: OlapScanNode olapNode = new OlapScanNode(ctx_.getNextNodeId(), tblRef.getDesc(), "OlapScanNode"); if (!Util.showHiddenColumns() && ((OlapTable) tblRef.getTable()).hasDeleteSign()) { - Expr conjunct = new BinaryPredicate(BinaryPredicate.Operator.EQ, - new SlotRef(tblRef.getAliasAsName(), Column.DELETE_SIGN), new IntLiteral(0)); + SlotRef deleteSignSlot = new SlotRef(tblRef.getAliasAsName(), Column.DELETE_SIGN); + deleteSignSlot.analyze(analyzer); + deleteSignSlot.getDesc().setIsMaterialized(true); + Expr conjunct = new BinaryPredicate(BinaryPredicate.Operator.EQ, deleteSignSlot, new IntLiteral(0)); conjunct.analyze(analyzer); analyzer.registerConjunct(conjunct, tblRef.getDesc().getId()); }