You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by li...@apache.org on 2022/07/14 11:15:50 UTC
[doris] branch repair_outer_join_0714 updated: [fix](planner)nullable info in IntermediateTuple do not be serialized in hash join node (#10848)
This is an automated email from the ASF dual-hosted git repository.
lingmiao pushed a commit to branch repair_outer_join_0714
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/repair_outer_join_0714 by this push:
new 27325a5ff3 [fix](planner)nullable info in IntermediateTuple do not be serialized in hash join node (#10848)
27325a5ff3 is described below
commit 27325a5ff341321b568226ce43d29278358238ba
Author: morrySnow <10...@users.noreply.github.com>
AuthorDate: Thu Jul 14 19:15:43 2022 +0800
[fix](planner)nullable info in IntermediateTuple do not be serialized in hash join node (#10848)
---
fe/fe-core/src/main/java/org/apache/doris/planner/HashJoinNode.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/HashJoinNode.java b/fe/fe-core/src/main/java/org/apache/doris/planner/HashJoinNode.java
index b79a2345e1..7eda81014a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/HashJoinNode.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/HashJoinNode.java
@@ -583,6 +583,7 @@ public class HashJoinNode extends PlanNode {
originToIntermediateSmap.put(new SlotRef(slotDescriptor), new SlotRef(intermediateSlotDesc));
}
}
+ vIntermediateLeftTupleDesc.computeMemLayout();
// right
originTidsToIntermediateTidMap.put(getChild(1).getOutputTupleIds(), vIntermediateRightTupleDesc.getId());
for (TupleDescriptor tupleDescriptor : analyzer.getDescTbl().getTupleDesc(getChild(1).getOutputTupleIds())) {
@@ -595,6 +596,7 @@ public class HashJoinNode extends PlanNode {
originToIntermediateSmap.put(new SlotRef(slotDescriptor), new SlotRef(intermediateSlotDesc));
}
}
+ vIntermediateRightTupleDesc.computeMemLayout();
// 3. replace srcExpr by intermediate tuple
Preconditions.checkState(vSrcToOutputSMap != null);
vSrcToOutputSMap.substituteLhs(originToIntermediateSmap, analyzer);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org