rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-27 18:30:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore

Browse Source 
Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2026-05-15 16:04:37 +08:00
parent c3f378dc68
commit 4b3efba805
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/flow/src/batching_mode/utils.rs
View File

@@ -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.
}