From db980787ace370b701fe7c705c0f01af1f8c1c51 Mon Sep 17 00:00:00 2001 From: Joseph Koshakow Date: Thu, 14 Nov 2024 14:54:23 -0500 Subject: [PATCH] Fix some issues --- src/adapter/src/catalog/apply.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/adapter/src/catalog/apply.rs b/src/adapter/src/catalog/apply.rs index ba4ee758924e7..0143867d7fe88 100644 --- a/src/adapter/src/catalog/apply.rs +++ b/src/adapter/src/catalog/apply.rs @@ -101,7 +101,7 @@ impl CatalogState { local_expression_cache: &mut LocalExpressionCache, ) -> Vec> { 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::new(); for (_, updates) in &updates.into_iter().group_by(|update| update.ts) { @@ -1870,7 +1870,7 @@ fn sort_updates_inner(updates: Vec, state: &CatalogState) -> Vec, state: &CatalogState) -> Vec (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