This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new ceef19ab7a2 [fix](spill) SpillStream's writer maybe may not have been
finalized (#32931)
ceef19ab7a2 is described below
commit ceef19ab7a271dfc7ccdb69005b59c5793edaf33
Author: Jerry Hu <[email protected]>
AuthorDate: Thu Mar 28 10:14:19 2024 +0800
[fix](spill) SpillStream's writer maybe may not have been finalized (#32931)
---
be/src/pipeline/exec/partitioned_aggregation_sink_operator.cpp | 3 +++
1 file changed, 3 insertions(+)
diff --git a/be/src/pipeline/exec/partitioned_aggregation_sink_operator.cpp
b/be/src/pipeline/exec/partitioned_aggregation_sink_operator.cpp
index b869efe0f9a..87eae081d08 100644
--- a/be/src/pipeline/exec/partitioned_aggregation_sink_operator.cpp
+++ b/be/src/pipeline/exec/partitioned_aggregation_sink_operator.cpp
@@ -170,6 +170,9 @@ Status
PartitionedAggSinkOperatorX::sink(doris::RuntimeState* state, vectorized:
if (revocable_mem_size(state) > 0) {
RETURN_IF_ERROR(revoke_memory(state));
} else {
+ for (auto& partition :
local_state._shared_state->spill_partitions) {
+ RETURN_IF_ERROR(partition->finish_current_spilling(eos));
+ }
local_state._dependency->set_ready_to_read();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
