diff --git a/src/meta/src/rpc/ddl_controller.rs b/src/meta/src/rpc/ddl_controller.rs
index 983140dbb1e82..492de31fb64a5 100644
--- 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
index 4ef0d4df2bc1f..c36afeeaee6a3 100644
--- 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 {