diff --git a/src/meta/src/manager/catalog/database.rs b/src/meta/src/manager/catalog/database.rs
index 735ef4c338e6a..56e14486adedc 100644
--- a/src/meta/src/manager/catalog/database.rs
+++ b/src/meta/src/manager/catalog/database.rs
@@ -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
@@ -463,11 +462,6 @@ impl DatabaseManager {
         self.in_progress_creation_streaming_job.keys().cloned()
     }
 
-    pub fn clear_creating_stream_jobs(&mut self) {
-        self.in_progress_creation_tracker.clear();
-        self.in_progress_creation_streaming_job.clear();
-    }
-
     pub fn mark_creating_tables(&mut self, tables: &[Table]) {
         self.in_progress_creating_tables
             .extend(tables.iter().map(|t| (t.id, t.clone())));
diff --git a/src/meta/src/manager/catalog/mod.rs b/src/meta/src/manager/catalog/mod.rs
index 5557cb109e97d..a20f0a1041a20 100644
--- a/src/meta/src/manager/catalog/mod.rs
+++ b/src/meta/src/manager/catalog/mod.rs
@@ -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