This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 88085d9076a2ba921735039af37e2b6ccd894dee Author: zhangstar333 <[email protected]> AuthorDate: Sat Jul 29 12:44:44 2023 +0800 [bug](distinct-agg) fix distinct-agg outblock columns size not equal key size (#22357) * [imporve](flex) support scientific notation(aEb) parser * update * [bug](distinct-agg) fix distinct-agg outblock columns size not equal key size --- be/src/pipeline/exec/distinct_streaming_aggregation_source_operator.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/pipeline/exec/distinct_streaming_aggregation_source_operator.cpp b/be/src/pipeline/exec/distinct_streaming_aggregation_source_operator.cpp index f91fd3fbe3..fb653bdcbd 100644 --- a/be/src/pipeline/exec/distinct_streaming_aggregation_source_operator.cpp +++ b/be/src/pipeline/exec/distinct_streaming_aggregation_source_operator.cpp @@ -46,7 +46,7 @@ Status DistinctStreamingAggSourceOperator::pull_data(RuntimeState* state, vector RETURN_IF_ERROR(_data_queue->get_block_from_queue(&agg_block)); if (agg_block != nullptr) { block->swap(*agg_block); - agg_block->clear_column_data(_node->row_desc().num_materialized_slots()); + agg_block->clear_column_data(block->columns()); _data_queue->push_free_block(std::move(agg_block)); } if (_data_queue->data_exhausted()) { //the sink is eos or reached limit --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
