diff --git a/src/operator/src/insert.rs b/src/operator/src/insert.rs index 3a3899a8c2d2..cbfc4aaa32aa 100644 --- a/src/operator/src/insert.rs +++ b/src/operator/src/insert.rs @@ -212,8 +212,8 @@ impl Inserter { .await?; let name2info = table_infos - .iter() - .map(|(_, info)| (info.name.clone(), info.clone())) + .values() + .map(|info| (info.name.clone(), info.clone())) .collect::>(); let inserts = RowToRegion::new( name2info, @@ -260,8 +260,8 @@ impl Inserter { ) .await?; let name2info = table_infos - .iter() - .map(|(_, info)| (info.name.clone(), info.clone())) + .values() + .map(|info| (info.name.clone(), info.clone())) .collect::>(); let inserts = RowToRegion::new(name2info, instant_table_ids, &self.partition_manager) .convert(requests)