From 0ec4ed804d9e24330af63d39c99e2de9c349ddfc Mon Sep 17 00:00:00 2001 From: WenyXu Date: Mon, 10 Feb 2025 14:22:51 +0000 Subject: [PATCH] fix: fix alter logic bug --- src/metric-engine/src/engine/alter.rs | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/src/metric-engine/src/engine/alter.rs b/src/metric-engine/src/engine/alter.rs index 1c50dfd68b..32978aec2f 100644 --- a/src/metric-engine/src/engine/alter.rs +++ b/src/metric-engine/src/engine/alter.rs @@ -122,14 +122,10 @@ impl MetricEngineInner { *region_id, columns .iter() - .flat_map(|col| { + .map(|col| { let column_name = col.column_metadata.column_schema.name.as_str(); - if new_column_names.contains(column_name) { - let column_metadata = *physical_schema_map.get(column_name).unwrap(); - Some((column_metadata.column_schema.name.as_str(), column_metadata)) - } else { - None - } + let column_metadata = *physical_schema_map.get(column_name).unwrap(); + (column_name, column_metadata) }) .collect::>(), )