From aecf6e09a9fd58f6cc7db8419d9e6a69d7cde08b Mon Sep 17 00:00:00 2001 From: zy-kkk Date: Sun, 3 Jul 2022 20:22:26 +0800 Subject: [PATCH] [fix] fix agg_memleak (#10571) The previous code did not call 'destroy' to release the resource after the' create 'operation, resulting in a memory leak. So I added Destroy --- be/src/vec/exec/vaggregation_node.cpp | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/be/src/vec/exec/vaggregation_node.cpp b/be/src/vec/exec/vaggregation_node.cpp index 68c48897ec..bbd94134fb 100644 --- a/be/src/vec/exec/vaggregation_node.cpp +++ b/be/src/vec/exec/vaggregation_node.cpp @@ -719,6 +719,10 @@ Status AggregationNode::_pre_agg_with_serialized_key(doris::vectorized::Block* i } } + for (size_t i = 0; i < rows; ++i) { + _destroy_agg_status(_streaming_pre_places[i]); + } + if (!mem_reuse) { ColumnsWithTypeAndName columns_with_schema; for (int i = 0; i < key_size; ++i) {