From 4b3efba805c50abd5ed05fb2b9a321639ac3948e Mon Sep 17 00:00:00 2001 From: discord9 Date: Fri, 15 May 2026 16:04:37 +0800 Subject: [PATCH] chore Signed-off-by: discord9 --- src/flow/src/batching_mode/utils.rs | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/flow/src/batching_mode/utils.rs b/src/flow/src/batching_mode/utils.rs index 073f9c6947..d4e0c07f45 100644 --- a/src/flow/src/batching_mode/utils.rs +++ b/src/flow/src/batching_mode/utils.rs @@ -153,11 +153,12 @@ pub fn analyze_incremental_aggregate_plan( let alias_name = alias.name.clone(); let mut col_names = Vec::new(); find_column_names(&alias.expr, &mut col_names); - if col_names.len() == 1 { - if let Some(col_name) = col_names.into_iter().next() { - output_aliases.entry(col_name).or_insert(alias_name); - } + if col_names.len() == 1 + && let Some(col_name) = col_names.into_iter().next() + { + output_aliases.entry(col_name).or_insert(alias_name); } + // If >1 column references detected (e.g., COALESCE(sum(x), sum(y))), // intentionally skip alias mapping — the merge semantics are ambiguous. }