Refactor error handling in ddl_controller.rs

risingwavelabs · Jul 30, 2024 · e8178e4 · e8178e4
1 parent 453ada2
commit e8178e4
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/src/meta/src/rpc/ddl_controller.rs b/src/meta/src/rpc/ddl_controller.rs
@@ -1091,11 +1091,8 @@ impl DdlController {
 
         if let Some(creating_sink_table_fragments) = creating_sink_table_fragments {
             let sink_fragment = creating_sink_table_fragments.sink_fragment().unwrap();
-
-            let sink = sink.unwrap();
-
+            let sink = sink.expect("sink not found");
             let uniq_name = &format!("{}.{}.{}", sink.database_id, sink.schema_id, sink.name);
-
             Self::inject_replace_table_plan_for_sink(
                 Some(sink.id),
                 &sink_fragment,