From 76a59ad7a6cc74d1d97ab731f074fb7687fdfa81 Mon Sep 17 00:00:00 2001 From: zhangstar333 <2561612514@qq.com> Date: Tue, 12 Mar 2024 17:56:10 +0800 Subject: [PATCH] update --- .../exec/distinct_streaming_aggregation_operator.cpp | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/be/src/pipeline/exec/distinct_streaming_aggregation_operator.cpp b/be/src/pipeline/exec/distinct_streaming_aggregation_operator.cpp index da2e5595b1248a..7983b269488eca 100644 --- a/be/src/pipeline/exec/distinct_streaming_aggregation_operator.cpp +++ b/be/src/pipeline/exec/distinct_streaming_aggregation_operator.cpp @@ -250,17 +250,6 @@ Status DistinctStreamingAggLocalState::_distinct_pre_agg_with_serialized_key( // need use _cur_num_rows_returned to decide whether to do continue emplace into hash table _cur_num_rows_returned += _distinct_row.size(); - // if (stop_emplace_flag) { - // vectorized::ColumnsWithTypeAndName columns_with_schema; - // for (int i = 0; i < key_size; ++i) { - // columns_with_schema.emplace_back(key_columns[i]->assume_mutable(), - // _probe_expr_ctxs[i]->root()->data_type(), - // _probe_expr_ctxs[i]->root()->expr_name()); - // } - // out_block->swap(vectorized::Block(columns_with_schema)); - // in_block->clear(); - // return Status::OK(); - // } bool mem_reuse = _parent->cast()._make_nullable_keys.empty() && out_block->mem_reuse(); if (mem_reuse) {