Skip to content

Commit

Permalink
fix: don't clean in-memory tracker when clean persist table catalog
Browse files Browse the repository at this point in the history
  • Loading branch information
yezizp2012 committed Dec 4, 2023
1 parent db2239d commit 6738a24
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 3 deletions.
3 changes: 1 addition & 2 deletions src/meta/src/manager/catalog/database.rs
Original file line number Diff line number Diff line change
Expand Up @@ -417,8 +417,7 @@ impl DatabaseManager {
}

pub fn has_in_progress_creation(&self, relation: &RelationKey) -> bool {
self.in_progress_creation_tracker
.contains(&relation.clone())
self.in_progress_creation_tracker.contains(relation)
}

/// For all types of DDL
Expand Down
1 change: 0 additions & 1 deletion src/meta/src/manager/catalog/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -885,7 +885,6 @@ impl CatalogManager {
self.env.event_log_manager_ref().add_event_logs(event_logs);
}

database_core.clear_creating_stream_jobs();
let user_core = &mut core.user;
for table in &tables_to_clean {
// If table type is internal, no need to update the ref count OR
Expand Down

0 comments on commit 6738a24

Please sign in to comment.