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

[pipelineX](join) Fix hash join (#23895)

Browse Source
This commit is contained in:
Gabriel
2023-09-06 11:37:15 +08:00
committed by GitHub
parent 45fd23c153
commit 47e47c575b
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
be/src/pipeline/pipeline_x/operator.cpp
View File

@ -242,11 +242,13 @@ Status StatefulOperatorX<LocalStateType>::get_block(RuntimeState* state, vectori
}
if (!need_more_input_data(state)) {
RETURN_IF_ERROR(pull(state, block, source_state));
if (source_state != SourceState::FINISHED && !need_more_input_data(state)) {
SourceState new_state = SourceState::DEPEND_ON_SOURCE;
RETURN_IF_ERROR(pull(state, block, new_state));
if (new_state == SourceState::FINISHED) {
source_state = SourceState::FINISHED;
} else if (!need_more_input_data(state)) {
source_state = SourceState::MORE_DATA;
} else if (source_state != SourceState::FINISHED &&
source_state == SourceState::MORE_DATA) {
} else if (source_state == SourceState::MORE_DATA) {
source_state = local_state._child_source_state;
}
}