This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 844dd8b2cec9514d5f609cd5a8fd6967ccd03e59 Author: Jerry Hu <[email protected]> AuthorDate: Thu Mar 21 13:45:36 2024 +0800 [fix](spill) should wait for merging done before read agg result (#32537) --- be/src/pipeline/exec/partitioned_aggregation_source_operator.cpp | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/be/src/pipeline/exec/partitioned_aggregation_source_operator.cpp b/be/src/pipeline/exec/partitioned_aggregation_source_operator.cpp index 909de78478e..82bb25e674c 100644 --- a/be/src/pipeline/exec/partitioned_aggregation_source_operator.cpp +++ b/be/src/pipeline/exec/partitioned_aggregation_source_operator.cpp @@ -132,6 +132,12 @@ Status PartitionedAggSourceOperatorX::get_block(RuntimeState* state, vectorized: RETURN_IF_ERROR(local_state._status); RETURN_IF_ERROR(local_state.initiate_merge_spill_partition_agg_data(state)); + + /// When `_is_merging` is true means we are reading spilled data and merging the data into hash table. + if (local_state._is_merging) { + return Status::OK(); + } + auto* runtime_state = local_state._runtime_state.get(); RETURN_IF_ERROR(_agg_source_operator->get_block(runtime_state, block, eos)); if (local_state._runtime_state) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
