diff --git a/src/frontend/src/handler/create_mv.rs b/src/frontend/src/handler/create_mv.rs index 83d8759735899..4fbb9f972ec41 100644 --- a/src/frontend/src/handler/create_mv.rs +++ b/src/frontend/src/handler/create_mv.rs @@ -15,7 +15,6 @@ use std::collections::HashSet; use either::Either; -use itertools::Itertools; use pgwire::pg_response::{PgResponse, StatementType}; use risingwave_common::acl::AclMode; use risingwave_common::catalog::{FunctionId, ObjectId, TableId}; diff --git a/src/meta/src/rpc/ddl_controller.rs b/src/meta/src/rpc/ddl_controller.rs index d318058905102..f4610ee82cd52 100644 --- a/src/meta/src/rpc/ddl_controller.rs +++ b/src/meta/src/rpc/ddl_controller.rs @@ -36,10 +36,9 @@ use risingwave_connector::source::{ }; use risingwave_connector::{dispatch_source_prop, WithOptionsSecResolved}; use risingwave_meta_model::object::ObjectType; -use risingwave_meta_model::prelude::ObjectDependency; use risingwave_meta_model::{ - object_dependency, ConnectionId, DatabaseId, FunctionId, IndexId, ObjectId, SchemaId, SecretId, - SinkId, SourceId, SubscriptionId, TableId, UserId, ViewId, + ConnectionId, DatabaseId, FunctionId, IndexId, ObjectId, SchemaId, SecretId, SinkId, SourceId, + SubscriptionId, TableId, UserId, ViewId, }; use risingwave_pb::catalog::{ Comment, Connection, CreateType, Database, Function, PbSink, Schema, Secret, Sink, Source, @@ -59,7 +58,6 @@ use risingwave_pb::stream_plan::{ Dispatcher, DispatcherType, FragmentTypeFlag, MergeNode, PbStreamFragmentGraph, StreamFragmentGraph as StreamFragmentGraphProto, }; -use sea_orm::{EntityTrait, Set}; use thiserror_ext::AsReport; use tokio::sync::Semaphore; use tokio::time::sleep;