fix: fix alter logic bug

This commit is contained in:
WenyXu
2025-02-10 14:22:51 +00:00
parent cc435234a4
commit 0ec4ed804d

View File

@@ -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::<HashMap<_, _>>(),
)