diff --git a/be/src/vec/olap/block_reader.cpp b/be/src/vec/olap/block_reader.cpp index f929da979df132..681b6d4e55da7f 100644 --- a/be/src/vec/olap/block_reader.cpp +++ b/be/src/vec/olap/block_reader.cpp @@ -347,7 +347,9 @@ void BlockReader::_update_agg_value(MutableColumns& columns, int begin, int end, if (is_close) { function->insert_result_into(place, *columns[_return_columns_loc[idx]]); - function->create(place); // reset aggregate data + // reset aggregate data + function->destroy(place); + function->create(place); } } }