Skip to content

Commit

Permalink
Fix some issues
Browse files Browse the repository at this point in the history
  • Loading branch information
jkosh44 committed Nov 14, 2024
1 parent f4ec8a9 commit db98078
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/adapter/src/catalog/apply.rs
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,7 @@ impl CatalogState {
local_expression_cache: &mut LocalExpressionCache,
) -> Vec<BuiltinTableUpdate<&'static BuiltinTable>> {
let mut builtin_table_updates = Vec::with_capacity(updates.len());
let updates = sort_updates(updates, &self);
let updates = sort_updates(updates, self);

let mut groups: Vec<Vec<_>> = Vec::new();
for (_, updates) in &updates.into_iter().group_by(|update| update.ts) {
Expand Down Expand Up @@ -1870,7 +1870,7 @@ fn sort_updates_inner(updates: Vec<StateUpdate>, state: &CatalogState) -> Vec<St
for (item, _, _) in &item_updates {
item_id_lookup
.entry(item.schema_id)
.or_insert_with(|| HashMap::new())
.or_insert_with(HashMap::new)
.insert(item.name.clone(), item.global_id);
}

Expand All @@ -1893,7 +1893,7 @@ fn sort_updates_inner(updates: Vec<StateUpdate>, state: &CatalogState) -> Vec<St
name.0[1].as_str(),
name.0[2].as_str(),
),
2 => (None, name.0[1].as_str(), name.0[2].as_str()),
2 => (None, name.0[0].as_str(), name.0[1].as_str()),
_ => panic!("Invalid item name: {name:?}"),
};
let schema = state
Expand Down

0 comments on commit db98078

Please sign in to comment.