fmt

risingwavelabs · Jul 6, 2024 · 03c4310 · 03c4310
1 parent 516da40
commit 03c4310
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/src/meta/src/rpc/ddl_controller.rs b/src/meta/src/rpc/ddl_controller.rs
@@ -1612,7 +1612,7 @@ impl DdlController {
                         dummy_id,
                         &self.metadata_manager,
                         stream_ctx,
-                        Some(&s),
+                        Some(s),
                         Some(&table_fragments),
                         None,
                         &streaming_job,

diff --git a/src/meta/src/rpc/ddl_controller_v2.rs b/src/meta/src/rpc/ddl_controller_v2.rs
@@ -18,7 +18,6 @@ use risingwave_common::util::stream_graph_visitor::visit_fragment;
 use risingwave_meta_model_v2::object::ObjectType;
 use risingwave_meta_model_v2::ObjectId;
 use risingwave_pb::catalog::CreateType;
-use risingwave_pb::ddl_service::TableJobType;
 use risingwave_pb::stream_plan::stream_node::NodeBody;
 use risingwave_pb::stream_plan::update_mutation::PbMergeUpdate;
 use risingwave_pb::stream_plan::StreamFragmentGraph as StreamFragmentGraphProto;
@@ -33,7 +32,7 @@ use crate::model::{MetadataModel, StreamContext};
 use crate::rpc::ddl_controller::{
     fill_table_stream_graph_info, DdlController, DropMode, ReplaceTableInfo,
 };
-use crate::stream::{validate_sink, StreamFragmentGraph};
+use crate::stream::StreamFragmentGraph;
 use crate::MetaResult;
 
 impl DdlController {