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 bc88d34b16 [bug](distinct-agg) fix distinct-agg outblock columns size
not equal key size (#22357)
bc88d34b16 is described below
commit bc88d34b164546bf2ba173aef39b18a54595ac22
Author: zhangstar333 <87313068+zhangstar...@users.noreply.github.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
