diff --git a/be/src/vec/aggregate_functions/aggregate_function_map.h b/be/src/vec/aggregate_functions/aggregate_function_map.h index 83e96a8d236839..d56cbf21f31136 100644 --- a/be/src/vec/aggregate_functions/aggregate_function_map.h +++ b/be/src/vec/aggregate_functions/aggregate_function_map.h @@ -254,6 +254,7 @@ class AggregateFunctionMapAgg final Field key, value; columns[0]->get(i, key); if (key.is_null()) { + col.insert(Map {Array {}, Array {}}); continue; } diff --git a/regression-test/data/nereids_syntax_p0/mv/agg_mv_test.dat b/regression-test/data/nereids_syntax_p0/mv/agg_mv_test.dat index 1856abe0cb272e..1d1d05317a208e 100644 --- a/regression-test/data/nereids_syntax_p0/mv/agg_mv_test.dat +++ b/regression-test/data/nereids_syntax_p0/mv/agg_mv_test.dat @@ -24,3 +24,4 @@ null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null; 10;1;11;11;11;11;11;1.1;1.1;1.1;1.1;1.1;1.1;1.1;1.1;char12;char22;char32;varchar12;varchar22;varchar32;string2;2012-03-11;2012-03-11;2012-03-11 11:10:11;2012-03-11 11:10:11;2012-03-11 11:10:11;2012-03-11 11:10:11;[1];[1];[11];[11];[11];[11];[11];[1.1];[2012-03-11,2012-03-11];[2012-03-11 11:10:11];[2012-03-11,2012-03-11];[2012-03-11 11:10:11,2012-03-11 11:10:11,2012-03-11 11:10:11,2012-03-11 11:10:11];[char12,char22,char32];[char12,char22,char32,varchar12,varchar22,varchar32];[char22,char32,varchar12,varchar22,varchar32,string2];[1.1,1.1];ST_Point(17.1, 37.1);ST_Point(17.1, 37.1);90.35620117;59.939093;89.4274406433;58.9020987219;0;11;75.321;LINESTRING (1 1, 2 2);POLYGON ((1 1, 8 0, 48 34, 4 10, 1 1));{null:1,1:2,1:3};{null:1,1:2,2:3};{null:1,1:2};{null:1,1:2};{null:1,1:2};{null:1,1:2};{null:1,1.1:2};{null:1,1.1:2};{null:1,1.100:2};{null:1,"char1":2};{null:1,"vchar1":2};{null:1,"str1":2};{null:1,2012-03-11:2};{null:1,2012-03-11:2};{1:null,2:1,3:1};{1:null,2:1,3:2};{1:null,2:1};{1:null,2:1};{1:null,2:1};{1:null,2:1};{1:null,2:1.1};{1:null,2:1.1};{1:null,2:1.100};{1:null,2:"char1"};{1:null,2:"vchar1"};{1:null,2:"str1"};{1:null,2:2012-03-11};{1:null,2:2012-03-11};[];{"id":1} 11;1;12;12;12;12;12;1.2;1.2;1.2;1.2;1.2;1.2;1.2;1.2;char13;char23;char33;varchar13;varchar23;varchar33;string3;2012-03-12;2012-03-12;2012-03-12 12:11:12;2012-03-12 12:11:12;2012-03-12 12:11:12;2012-03-12 12:11:12;[1];[1];[12];[12];[12];[12];[12];[1.2];[2012-03-12,2012-03-12];[2012-03-12 12:11:12];[2012-03-12,2012-03-12];[2012-03-12 12:11:12,2012-03-12 12:11:12,2012-03-12 12:11:12,2012-03-12 12:11:12];[char13,char23,char33];[char13,char23,char33,varchar13,varchar23,varchar33];[char23,char33,varchar13,varchar23,varchar33,string3];[1.2,1.2];ST_Point(22.1, 22.1);ST_Point(22.1, 22.1);90.35620117;39.939093;89.4274406433;58.9020987219;0;12;100.321;LINESTRING (1 1, 2 2);POLYGON ((1 1, 9 4, 10 4, 4 1, 1 1));{null:1,1:2,1:3};{null:1,2:2,1:3};{null:1,2:2};{null:1,2:2};{null:1,2:2};{null:1,2:2};{null:1,2.2:2};{null:1,2.2:2};{null:1,2.200:2};{null:1,"char2":2};{null:1,"vchar2":2};{null:1,"str2":2};{null:1,2012-03-12:2};{null:1,2012-03-12:2};{1:null,2:1,3:1};{1:null,2:2,3:1};{1:null,2:2};{1:null,2:2};{1:null,2:2};{1:null,2:2};{1:null,2:2.2};{1:null,2:2.2};{1:null,2:2.200};{1:null,2:"char2"};{1:null,2:"vchar2"};{1:null,2:"str2"};{1:null,2:2012-03-12};{1:null,2:2012-03-12};[];{"id":1} null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null;null +null;0;1;1;1;1;1;0.1;0.1;0.1;0.1;0.1;0.1;0.1;0.1;char11;char21;char31;varchar11;varchar21;varchar31;string1;2012-03-01;2012-03-01;2012-03-01 01:00:01;2012-03-01 01:00:01;2012-03-01 01:00:01;2012-03-01 01:00:01;[0];[0];[1];[1];[1];[1];[1];[0.1];[2012-03-01,2012-03-01];[2012-03-01 01:00:01];[2012-03-01,2012-03-01];[2012-03-01 01:00:01,2012-03-01 01:00:01,2012-03-01 01:00:01,2012-03-01 01:00:01];[char11,char21,char31];[char11,char21,char31,varchar11,varchar21,varchar31];[char21,char31,varchar11,varchar21,varchar31,string1];[0.1,0.1];ST_Point(12.1, 32.1);ST_Point(12.1, 32.1);5;5;116.4274406433;39.9020987219;0;1;4.321;LINESTRING (1 1, 2 2);POLYGON ((0 0, 10 0, 10 10, 0 10, 0 0));{null:1,0:2,0:3};{null:1,1:2,2:3};{null:1,1:2};{null:1,1:2};{null:1,1:2};{null:1,1:2};{null:1,1.1:2};{null:1,1.1:2};{null:1,1.100:2};{null:1,"char1":2};{null:1,"vchar1":2};{null:1,"str1":2};{null:1,2012-03-01:2};{null:1,2012-03-01:2};{1:null,2:0,3:0};{1:null,2:1,3:2};{1:null,2:1};{1:null,2:1};{1:null,2:1};{1:null,2:1};{1:null,2:1.1};{1:null,2:1.1};{1:null,2:1.100};{1:null,2:"char1"};{1:null,2:"vchar1"};{1:null,2:"str1"};{1:null,2:2012-03-01};{1:null,2:2012-03-01};[];{"id":1} diff --git a/regression-test/data/nereids_syntax_p0/mv/aggregate/agg_sync_mv.out b/regression-test/data/nereids_syntax_p0/mv/aggregate/agg_sync_mv.out index 0cdfbc4a991d1f..848d637c916a93 100644 --- a/regression-test/data/nereids_syntax_p0/mv/aggregate/agg_sync_mv.out +++ b/regression-test/data/nereids_syntax_p0/mv/aggregate/agg_sync_mv.out @@ -1,6 +1,6 @@ -- This file is automatically generated. You should know what you did if you want to edit this -- !select_any_value -- -\N \N +\N 1 0 1 1 2 2 3 @@ -15,7 +15,7 @@ 11 12 -- !select_any_value_mv -- -\N \N +\N 1 0 1 1 2 2 3 @@ -30,7 +30,7 @@ 11 12 -- !select_approx_count_distinct -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -45,7 +45,7 @@ 11 1 -- !select_approx_count_distinct_mv -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -60,7 +60,7 @@ 11 1 -- !select_collect_set -- -\N [] +\N [1] 0 [1] 1 [2] 2 [3] @@ -75,7 +75,7 @@ 11 [12] -- !select_collect_set_mv -- -\N [] +\N [1] 0 [1] 1 [2] 2 [3] @@ -90,7 +90,7 @@ 11 [12] -- !select_collect_list -- -\N [] +\N [1] 0 [1, 1] 1 [2, 2] 2 [3, 3] @@ -105,7 +105,7 @@ 11 [12, 12] -- !select_collect_list_mv -- -\N [] +\N [1] 0 [1, 1] 1 [2, 2] 2 [3, 3] @@ -120,7 +120,7 @@ 11 [12, 12] -- !select_corr -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -135,7 +135,7 @@ 11 0.0 -- !select_corr_mv -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -150,7 +150,7 @@ 11 0.0 -- !select_percentile_array -- -\N [] +\N [1, 1, 1] 0 [1, 1, 1] 1 [2, 2, 2] 2 [3, 3, 3] @@ -165,7 +165,7 @@ 11 [12, 12, 12] -- !select_percentile_array_mv -- -\N [] +\N [1, 1, 1] 0 [1, 1, 1] 1 [2, 2, 2] 2 [3, 3, 3] @@ -210,7 +210,7 @@ 11 \N -- !select_count_by_enum -- -\N [{"cbe":{"null":2},"notnull":2,"null":0,"all":2}] +\N [{"cbe":{"string1":1,"null":2},"notnull":3,"null":0,"all":3}] 0 [{"cbe":{"string1":2},"notnull":2,"null":0,"all":2}] 1 [{"cbe":{"string2":2},"notnull":2,"null":0,"all":2}] 2 [{"cbe":{"string3":2},"notnull":2,"null":0,"all":2}] @@ -225,7 +225,7 @@ 11 [{"cbe":{"string3":2},"notnull":2,"null":0,"all":2}] -- !select_count_by_enum_mv -- -\N [{"cbe":{"null":2},"notnull":2,"null":0,"all":2}] +\N [{"cbe":{"string1":1,"null":2},"notnull":3,"null":0,"all":3}] 0 [{"cbe":{"string1":2},"notnull":2,"null":0,"all":2}] 1 [{"cbe":{"string2":2},"notnull":2,"null":0,"all":2}] 2 [{"cbe":{"string3":2},"notnull":2,"null":0,"all":2}] @@ -240,7 +240,7 @@ 11 [{"cbe":{"string3":2},"notnull":2,"null":0,"all":2}] -- !select_avg_weighted -- -\N \N +\N 1.0 0 1.0 1 2.0 2 3.0 @@ -255,7 +255,7 @@ 11 12.0 -- !select_avg_weighted_mv -- -\N \N +\N 1.0 0 1.0 1 2.0 2 3.0 @@ -360,7 +360,7 @@ 11 \N -- !select_bitmap_union_count -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -375,7 +375,7 @@ 11 1 -- !select_bitmap_union_count_mv -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -390,7 +390,7 @@ 11 1 -- !select_bitmap_union_int -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -405,7 +405,7 @@ 11 1 -- !select_bitmap_union_int_mv -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -450,7 +450,7 @@ 11 [12] -- !select_group_bit_and -- -\N \N +\N 1 0 1 1 2 2 3 @@ -465,7 +465,7 @@ 11 12 -- !select_group_bit_and_mv -- -\N \N +\N 1 0 1 1 2 2 3 @@ -480,7 +480,7 @@ 11 12 -- !select_group_bit_or -- -\N \N +\N 1 0 1 1 2 2 3 @@ -495,7 +495,7 @@ 11 12 -- !select_group_bit_or_mv -- -\N \N +\N 1 0 1 1 2 2 3 @@ -510,7 +510,7 @@ 11 12 -- !select_group_bit_xor -- -\N \N +\N 1 0 0 1 0 2 0 @@ -525,7 +525,7 @@ 11 0 -- !select_group_bit_xor_mv -- -\N \N +\N 1 0 0 1 0 2 0 @@ -570,7 +570,7 @@ 11 \N -- !select_hll_union_agg -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -585,7 +585,7 @@ 11 1 -- !select_hll_union_agg_mv -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -660,7 +660,7 @@ 11 0 -- !select_group_concat -- -\N \N +\N 1 0 1,1 1 2,2 2 3,3 @@ -675,7 +675,7 @@ 11 12,12 -- !select_group_concat_mv -- -\N \N +\N 1 0 1,1 1 2,2 2 3,3 @@ -690,7 +690,7 @@ 11 12,12 -- !select_multi_distinct_group_concat -- -\N \N +\N 1 0 1 1 2 2 3 @@ -705,7 +705,7 @@ 11 12 -- !select_multi_distinct_group_concat_mv -- -\N \N +\N 1 0 1 1 2 2 3 @@ -720,7 +720,7 @@ 11 12 -- !select_multi_distinct_sum0 -- -\N 0 +\N 1 0 1 1 2 2 3 @@ -735,7 +735,7 @@ 11 12 -- !select_multi_distinct_sum0_mv -- -\N 0 +\N 1 0 1 1 2 2 3 @@ -750,7 +750,7 @@ 11 12 -- !select_multi_distinct_sum -- -\N \N +\N 1 0 1 1 2 2 3 @@ -765,7 +765,7 @@ 11 12 -- !select_multi_distinct_sum_mv -- -\N \N +\N 1 0 1 1 2 2 3 @@ -780,7 +780,7 @@ 11 12 -- !select_histogram -- -\N {"num_buckets":0,"buckets":[]} +\N {"num_buckets":1,"buckets":[{"lower":"1","upper":"1","ndv":1,"count":1,"pre_sum":0}]} 0 {"num_buckets":1,"buckets":[{"lower":"1","upper":"1","ndv":1,"count":2,"pre_sum":0}]} 1 {"num_buckets":1,"buckets":[{"lower":"2","upper":"2","ndv":1,"count":2,"pre_sum":0}]} 2 {"num_buckets":1,"buckets":[{"lower":"3","upper":"3","ndv":1,"count":2,"pre_sum":0}]} @@ -795,7 +795,7 @@ 11 {"num_buckets":1,"buckets":[{"lower":"12","upper":"12","ndv":1,"count":2,"pre_sum":0}]} -- !select_histogram_mv -- -\N {"num_buckets":0,"buckets":[]} +\N {"num_buckets":1,"buckets":[{"lower":"1","upper":"1","ndv":1,"count":1,"pre_sum":0}]} 0 {"num_buckets":1,"buckets":[{"lower":"1","upper":"1","ndv":1,"count":2,"pre_sum":0}]} 1 {"num_buckets":1,"buckets":[{"lower":"2","upper":"2","ndv":1,"count":2,"pre_sum":0}]} 2 {"num_buckets":1,"buckets":[{"lower":"3","upper":"3","ndv":1,"count":2,"pre_sum":0}]} @@ -810,7 +810,7 @@ 11 {"num_buckets":1,"buckets":[{"lower":"12","upper":"12","ndv":1,"count":2,"pre_sum":0}]} -- !select_max_by -- -\N \N +\N 1 0 1 1 2 2 3 @@ -825,7 +825,7 @@ 11 12 -- !select_max_by_mv -- -\N \N +\N 1 0 1 1 2 2 3 @@ -840,7 +840,7 @@ 11 12 -- !select_min_by -- -\N \N +\N 1 0 1 1 2 2 3 @@ -855,7 +855,7 @@ 11 12 -- !select_min_by_mv -- -\N \N +\N 1 0 1 1 2 2 3 @@ -870,7 +870,7 @@ 11 12 -- !select_multi_distinct_count -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -885,7 +885,7 @@ 11 1 -- !select_multi_distinct_count_mv -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -900,7 +900,7 @@ 11 1 -- !select_ndv -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -915,7 +915,7 @@ 11 1 -- !select_ndv_mv -- -\N 0 +\N 1 0 1 1 1 2 1 @@ -930,7 +930,7 @@ 11 1 -- !select_covar -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -945,7 +945,7 @@ 11 0.0 -- !select_covar_mv -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -960,7 +960,7 @@ 11 0.0 -- !select_covar_samp -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -975,7 +975,7 @@ 11 0.0 -- !select_covar_samp_mv -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -990,7 +990,7 @@ 11 0.0 -- !select_percentile -- -\N \N +\N 1.0 0 1.0 1 2.0 2 3.0 @@ -1005,7 +1005,7 @@ 11 12.0 -- !select_percentile_mv -- -\N \N +\N 1.0 0 1.0 1 2.0 2 3.0 @@ -1020,7 +1020,7 @@ 11 12.0 -- !select_percentile_approx -- -\N \N +\N 1.0 0 1.0 1 2.0 2 3.0 @@ -1035,7 +1035,7 @@ 11 12.0 -- !select_percentile_approx_mv -- -\N \N +\N 1.0 0 1.0 1 2.0 2 3.0 @@ -1080,7 +1080,7 @@ 11 0 -- !select_sequence_match -- -\N \N +\N false 0 false 1 false 2 false @@ -1095,7 +1095,7 @@ 11 false -- !select_sequence_match_mv -- -\N \N +\N false 0 false 1 false 2 false @@ -1110,7 +1110,7 @@ 11 false -- !select_stddev -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1125,7 +1125,7 @@ 11 0.0 -- !select_stddev_mv -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1140,7 +1140,7 @@ 11 0.0 -- !select_stddev_pop -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1155,7 +1155,7 @@ 11 0.0 -- !select_stddev_pop_mv -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1170,7 +1170,7 @@ 11 0.0 -- !select_stddev_samp -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1185,7 +1185,7 @@ 11 0.0 -- !select_stddev_samp_mv -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1200,7 +1200,7 @@ 11 0.0 -- !select_sum0 -- -\N 0 +\N 1 0 2 1 4 2 6 @@ -1215,7 +1215,7 @@ 11 24 -- !select_sum0_mv -- -\N 0 +\N 1 0 2 1 4 2 6 @@ -1230,7 +1230,7 @@ 11 24 -- !select_topn -- -\N {"null":2} +\N {"null":2,"varchar11":1} 0 {"varchar11":2} 1 {"varchar12":2} 2 {"varchar13":2} @@ -1245,7 +1245,7 @@ 11 {"varchar13":2} -- !select_topn_mv -- -\N {"null":2} +\N {"null":2,"varchar11":1} 0 {"varchar11":2} 1 {"varchar12":2} 2 {"varchar13":2} @@ -1260,7 +1260,7 @@ 11 {"varchar13":2} -- !select_topn_array -- -\N ["null"] +\N ["null", "varchar11"] 0 ["varchar11"] 1 ["varchar12"] 2 ["varchar13"] @@ -1275,7 +1275,7 @@ 11 ["varchar13"] -- !select_topn_array_mv -- -\N ["null"] +\N ["null", "varchar11"] 0 ["varchar11"] 1 ["varchar12"] 2 ["varchar13"] @@ -1290,7 +1290,7 @@ 11 ["varchar13"] -- !select_topn_weighted -- -\N \N +\N ["varchar11"] 0 ["varchar11"] 1 ["varchar12"] 2 ["varchar13"] @@ -1305,7 +1305,7 @@ 11 ["varchar13"] -- !select_topn_weighted_mv -- -\N \N +\N ["varchar11"] 0 ["varchar11"] 1 ["varchar12"] 2 ["varchar13"] @@ -1320,7 +1320,7 @@ 11 ["varchar13"] -- !select_variance -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1335,7 +1335,7 @@ 11 0.0 -- !select_variance_mv -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1350,7 +1350,7 @@ 11 0.0 -- !select_var_pop -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1365,7 +1365,7 @@ 11 0.0 -- !select_var_pop_mv -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1380,7 +1380,7 @@ 11 0.0 -- !select_variance_samp -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1395,7 +1395,7 @@ 11 0.0 -- !select_variance_samp_mv -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1410,7 +1410,7 @@ 11 0.0 -- !select_var_samp -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1425,7 +1425,7 @@ 11 0.0 -- !select_var_samp_mv -- -\N \N +\N 0.0 0 0.0 1 0.0 2 0.0 @@ -1440,7 +1440,7 @@ 11 0.0 -- !select_window_funnel -- -\N \N +\N 1 0 1 1 0 2 0 @@ -1455,7 +1455,7 @@ 11 0 -- !select_window_funnel_mv -- -\N \N +\N 1 0 1 1 0 2 0 @@ -1470,7 +1470,7 @@ 11 0 -- !select_retention -- -\N \N +\N [0, 0] 0 [0, 0] 1 [0, 0] 2 [0, 0] @@ -1485,7 +1485,7 @@ 11 [0, 0] -- !select_retention_mv -- -\N \N +\N [0, 0] 0 [0, 0] 1 [0, 0] 2 [0, 0] @@ -1499,3 +1499,18 @@ 10 [0, 0] 11 [0, 0] +-- !test -- +\N {} +1 {0:"string1"} +2 {1:"string2"} +3 {2:"string3"} +4 {3:"string1"} +5 {4:"string2"} +6 {5:"string3"} +7 {6:"string1"} +8 {7:"string2"} +9 {8:"string3"} +10 {9:"string1"} +11 {10:"string2"} +12 {11:"string3"} + diff --git a/regression-test/suites/nereids_syntax_p0/mv/aggregate/agg_sync_mv.groovy b/regression-test/suites/nereids_syntax_p0/mv/aggregate/agg_sync_mv.groovy index ee5135aeabadb2..b0f384c472c848 100644 --- a/regression-test/suites/nereids_syntax_p0/mv/aggregate/agg_sync_mv.groovy +++ b/regression-test/suites/nereids_syntax_p0/mv/aggregate/agg_sync_mv.groovy @@ -531,4 +531,22 @@ suite("agg_sync_mv") { ''' file "../agg_mv_test.dat" } + + + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + sql "insert into agg_mv_test select * from agg_mv_test;" + + sql "set parallel_pipeline_task_num=1" + qt_test "select kbint, map_agg(id, kstr) from agg_mv_test group by kbint order by kbint;" }