[pipelineX](bug) fix distinct streaming agg (#24995)

2023-09-28 14:01:26 +08:00
parent 5ffb01a068
commit b35171b582
1 changed files with 3 additions and 2 deletions
--- 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);
                        }