From 3fcca2ccb27e14d24ca84d9c952975cf7f7ea285 Mon Sep 17 00:00:00 2001 From: BiteTheDDDDt Date: Fri, 6 Sep 2024 11:42:49 +0800 Subject: [PATCH] fix wrong result on map_agg with streaming agg --- be/src/vec/aggregate_functions/aggregate_function_map.h | 1 + 1 file changed, 1 insertion(+) diff --git a/be/src/vec/aggregate_functions/aggregate_function_map.h b/be/src/vec/aggregate_functions/aggregate_function_map.h index e0a19a34207d80..bc065d5d8121b4 100644 --- a/be/src/vec/aggregate_functions/aggregate_function_map.h +++ b/be/src/vec/aggregate_functions/aggregate_function_map.h @@ -224,6 +224,7 @@ class AggregateFunctionMapAgg final Field key, value; columns[0]->get(i, key); if (key.is_null()) { + col.insert(Map {Array {}, Array {}}); continue; }