This is an automated email from the ASF dual-hosted git repository.
yangzhg pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 5a6e926 fix join error when the table has enbale batch delete (#4734)
5a6e926 is described below
commit 5a6e926c7b20d6c56b894a1dfc3e5b4307375533
Author: Zhengguo Yang <[email protected]>
AuthorDate: Wed Oct 14 09:32:57 2020 +0800
fix join error when the table has enbale batch delete (#4734)
---
.../src/main/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 5384bcc..a8452f3 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 @@ public class SingleNodePlanner {
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());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
