This is an automated email from the ASF dual-hosted git repository.
gabriellee 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 b35171b582 [pipelineX](bug) fix distinct streaming agg (#24995)
b35171b582 is described below
commit b35171b58271b45d58d97171bd81b3aac0cd286b
Author: Gabriel <gabrielleeb...@gmail.com>
AuthorDate: Thu Sep 28 14:01:26 2023 +0800
[pipelineX](bug) fix distinct streaming agg (#24995)
---
.../pipeline/exec/distinct_streaming_aggregation_sink_operator.cpp | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/be/src/pipeline/exec/distinct_streaming_aggregation_sink_operator.cpp
b/be/src/pipeline/exec/distinct_streaming_aggregation_sink_operator.cpp
index 4fa798194c..9f0fafeb54 100644
--- a/be/src/pipeline/exec/distinct_streaming_aggregation_sink_operator.cpp
+++ b/be/src/pipeline/exec/distinct_streaming_aggregation_sink_operator.cpp
@@ -175,8 +175,9 @@ void
DistinctStreamingAggSinkLocalState::_emplace_into_hash_table_to_distinct(
agg_method.data.prefetch_by_hash(
_hash_values[i + HASH_MAP_PREFETCH_DIST]);
}
- auto result = state.emplace_with_key(agg_method.data,
keys[i],
- _hash_values[i],
i);
+ auto result = state.emplace_with_key(
+ agg_method.data,
state.pack_key_holder(keys[i], *_agg_arena_pool),
+ _hash_values[i], i);
if (result.is_inserted()) {
distinct_row.push_back(i);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
