minor

src/frontend/src/handler/create_table.rs

@@ -951,7 +951,6 @@ pub async fn handle_create_table(
         let context = OptimizerContext::from_handler_args(handler_args);
         let source_schema = check_create_table_with_source(context.with_options(), source_schema)?;
         let col_id_gen = ColumnIdGenerator::new_initial();
-        // let properties = context.with_options().inner().clone().into_iter().collect();
 
         let ((plan, source, table), job_type) = match (source_schema, cdc_table_info.as_ref()) {
             (Some(source_schema), None) => (

src/meta/service/src/ddl_service.rs

@@ -204,8 +204,8 @@ impl DdlService for DdlServiceImpl {
                     });
                 }
 
+                // The id of stream job has been set above
                 let stream_job = StreamingJob::Source(source);
-
                 let version = self
                     .ddl_controller
                     .run_command(DdlCommand::CreateStreamingJob(

src/meta/src/manager/streaming_job.rs

@@ -88,7 +88,9 @@ impl StreamingJob {
                 index_table.id = id;
             }
             StreamingJob::Source(_) => {
-                // do nothing
+                // The id of source is set in `DdlServiceImpl::create_source`,
+                // so do nothing here.
+                unreachable!()
             }
         }
     }