diff --git a/src/share/aggregate/iaggregate.h b/src/share/aggregate/iaggregate.h index b9e8370aa0..a14ccb5f8b 100644 --- a/src/share/aggregate/iaggregate.h +++ b/src/share/aggregate/iaggregate.h @@ -222,10 +222,15 @@ public: agg_ctx, agg_col_id, cur_group_id, output_start_idx, loop_cnt, skip); break; } - case common::VEC_UNIFORM_CONST: + case common::VEC_UNIFORM_CONST: { + // must be null + ret = ret = collect_group_results>( + agg_ctx, agg_col_id, cur_group_id, output_start_idx, loop_cnt, skip); + break; + } case common::VEC_UNIFORM: { // must be null - ret = collect_group_results>( + ret = collect_group_results>( agg_ctx, agg_col_id, cur_group_id, output_start_idx, loop_cnt, skip); break; } @@ -272,13 +277,18 @@ public: agg_ctx, agg_col_id, output_start_idx, batch_size, rows, row_meta); break; } - case VEC_UNIFORM_CONST: - case VEC_UNIFORM: { + case VEC_UNIFORM_CONST: { // must be null type ret = collect_group_results>( agg_ctx, agg_col_id, output_start_idx, batch_size, rows, row_meta); break; } + case VEC_UNIFORM: { + // must be null type + ret = collect_group_results>( + agg_ctx, agg_col_id, output_start_idx, batch_size, rows, row_meta); + break; + } default: { ret = OB_ERR_UNEXPECTED; SQL_LOG(WARN, "invalid result format", K(ret), K(res_fmt), K(agg_col_id));