This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch spill_and_reserve
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/spill_and_reserve by this push:
new 6ca1e4d6e5a [fix](spill) Avoid reading too much data while recoverying
from disk (#45828)
6ca1e4d6e5a is described below
commit 6ca1e4d6e5ac02b62886b6371dad236cd702c848
Author: Jerry Hu <hushengg...@selectdb.com>
AuthorDate: Tue Dec 24 15:11:08 2024 +0800
[fix](spill) Avoid reading too much data while recoverying from disk
(#45828)
---
be/src/pipeline/exec/partitioned_aggregation_source_operator.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/pipeline/exec/partitioned_aggregation_source_operator.cpp
b/be/src/pipeline/exec/partitioned_aggregation_source_operator.cpp
index 57ebfd24558..8e221a1c7e2 100644
--- a/be/src/pipeline/exec/partitioned_aggregation_source_operator.cpp
+++ b/be/src/pipeline/exec/partitioned_aggregation_source_operator.cpp
@@ -261,7 +261,7 @@ Status
PartitionedAggLocalState::recover_blocks_from_disk(RuntimeState* state, b
while (!state->is_cancelled() && !has_agg_data &&
!_shared_state->spill_partitions.empty()) {
while (!_shared_state->spill_partitions[0]->spill_streams_.empty()
&&
- !state->is_cancelled()) {
+ !state->is_cancelled() && !has_agg_data) {
auto& stream =
_shared_state->spill_partitions[0]->spill_streams_[0];
stream->set_read_counters(profile());
vectorized::Block block;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
