database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](spill) fix hash join error 'invalid slot id' (#33273)

Browse Source
This commit is contained in:
TengJianPing
2024-04-07 14:07:06 +08:00
committed by yiguolei
parent 2092a862fc
commit e6e2099256
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
be/src/pipeline/exec/partitioned_hash_join_probe_operator.cpp
View File

@ -494,27 +494,26 @@ Status PartitionedHashJoinProbeOperatorX::init(const TPlanNode& tnode, RuntimeSt
return _probe_operator->init(tnode_, state);
}
Status PartitionedHashJoinProbeOperatorX::prepare(RuntimeState* state) {
// here do NOT call `OperatorXBase::prepare(state)`
// RETURN_IF_ERROR(OperatorXBase::prepare(state));
for (auto& conjunct : _conjuncts) {
RETURN_IF_ERROR(conjunct->prepare(state, intermediate_row_desc()));
}
RETURN_IF_ERROR(vectorized::VExpr::prepare(_projections, state, intermediate_row_desc()));
RETURN_IF_ERROR(vectorized::VExpr::prepare(_output_expr_ctxs, state, *_intermediate_row_desc));
RETURN_IF_ERROR(_probe_operator->set_child(_child_x));
// to avoid prepare _child_x twice
auto child_x = std::move(_child_x);
RETURN_IF_ERROR(JoinProbeOperatorX::prepare(state));
RETURN_IF_ERROR(_probe_operator->set_child(child_x));
DCHECK(_build_side_child != nullptr);
_probe_operator->set_build_side_child(_build_side_child);
RETURN_IF_ERROR(_sink_operator->set_child(_build_side_child));
RETURN_IF_ERROR(_probe_operator->prepare(state));
RETURN_IF_ERROR(_sink_operator->prepare(state));
_child_x = std::move(child_x);
return Status::OK();
}
Status PartitionedHashJoinProbeOperatorX::open(RuntimeState* state) {
// to avoid open _child_x twice
auto child_x = std::move(_child_x);
RETURN_IF_ERROR(JoinProbeOperatorX::open(state));
RETURN_IF_ERROR(_probe_operator->open(state));
RETURN_IF_ERROR(_sink_operator->open(state));
_child_x = std::move(child_x);
return Status::OK();
}