diff --git a/src/frontend/src/catalog/table_catalog.rs b/src/frontend/src/catalog/table_catalog.rs
index 702baa961b8a2..c8b7b4ef437e4 100644
--- a/src/frontend/src/catalog/table_catalog.rs
+++ b/src/frontend/src/catalog/table_catalog.rs
@@ -654,6 +654,7 @@ mod tests {
             stream_job_status: PbStreamJobStatus::Creating.into(),
             create_type: PbCreateType::Foreground.into(),
             description: Some("description".to_string()),
+            incoming_sinks: vec![],
         }
         .into();
 
@@ -710,7 +711,8 @@ mod tests {
                 initialized_at_epoch: None,
                 cleaned_by_watermark: false,
                 create_type: CreateType::Foreground,
-                description: Some("description".to_string())
+                description: Some("description".to_string()),
+                incoming_sinks: vec![],
             }
         );
         assert_eq!(table, TableCatalog::from(table.to_prost(0, 0)));
diff --git a/src/meta/src/rpc/ddl_controller.rs b/src/meta/src/rpc/ddl_controller.rs
index f5188fb688c1b..246aff5c0b22a 100644
--- a/src/meta/src/rpc/ddl_controller.rs
+++ b/src/meta/src/rpc/ddl_controller.rs
@@ -618,7 +618,6 @@ impl DdlController {
                         if let NodeBody::Merge(m) = body && m.upstream_actor_id.is_empty() {
                             target_fragment_id = Some(*fragment_id);
                             fragment.fragment_type_mask &= !(FragmentTypeFlag::Source as u32);
-                            return
                         };
                     })
                 };
@@ -683,7 +682,7 @@ impl DdlController {
             .map(|(a, _)| a as u32)
             .collect_vec();
 
-        for actor_id in sink_actor_ids.iter() {
+        for actor_id in &sink_actor_ids {
             let downstream_actor_id = sink_to_merge.get(actor_id).unwrap();
 
             replace_table_ctx.dispatchers.insert(
diff --git a/src/storage/src/filter_key_extractor.rs b/src/storage/src/filter_key_extractor.rs
index 6538042566537..14eb24d551fe7 100644
--- a/src/storage/src/filter_key_extractor.rs
+++ b/src/storage/src/filter_key_extractor.rs
@@ -552,6 +552,7 @@ mod tests {
             stream_job_status: PbStreamJobStatus::Created.into(),
             create_type: PbCreateType::Foreground.into(),
             description: None,
+            incoming_sinks: vec![],
         }
     }