minor

risingwavelabs · Oct 24, 2023 · eebf0f6 · eebf0f6
1 parent b6e5633
commit eebf0f6
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/src/meta/service/src/ddl_service.rs b/src/meta/service/src/ddl_service.rs
@@ -437,7 +437,11 @@ impl DdlService for DdlServiceImpl {
                     CdcSourceType::from(connector.as_str()),
                     CdcSourceType::Mysql
                 ) {
-                    let server_id = self.gen_unique_id_u64::<{ IdCategory::MySqlCdc }>().await?;
+                    let server_id = self
+                        .env
+                        .id_gen_manager()
+                        .generate::<{ IdCategory::MySqlCdc }>()
+                        .await?;
                     fill_cdc_mysql_server_id(server_id, &mut fragment_graph);
                 }
             }
@@ -753,11 +757,6 @@ impl DdlServiceImpl {
         Ok(id)
     }
 
-    async fn gen_unique_id_u64<const C: IdCategoryType>(&self) -> MetaResult<u64> {
-        let id = self.env.id_gen_manager().generate::<C>().await?;
-        Ok(id)
-    }
-
     async fn validate_connection(&self, connection_id: ConnectionId) -> MetaResult<()> {
         let connection = self
             .catalog_manager