diff --git a/src/meta/src/controller/catalog.rs b/src/meta/src/controller/catalog.rs
index c1e2e091c0a8a..d0067d495c79e 100644
--- a/src/meta/src/controller/catalog.rs
+++ b/src/meta/src/controller/catalog.rs
@@ -2910,6 +2910,7 @@ impl CatalogController {
         let inner = self.inner.read().await;
         let subscription_objs: Vec<(SubscriptionId, ObjectId, i64, DatabaseId)> =
             Subscription::find()
+                .select_only()
                 .select_column(subscription::Column::SubscriptionId)
                 .select_column(subscription::Column::DependentTableId)
                 .select_column(subscription::Column::RetentionSeconds)
diff --git a/src/meta/src/rpc/ddl_controller.rs b/src/meta/src/rpc/ddl_controller.rs
index e50061d09b97d..01b6577dab43e 100644
--- a/src/meta/src/rpc/ddl_controller.rs
+++ b/src/meta/src/rpc/ddl_controller.rs
@@ -172,6 +172,7 @@ impl DdlCommand {
             | DdlCommand::DropStreamingJob(_, _, _)
             | DdlCommand::DropConnection(_)
             | DdlCommand::DropSecret(_)
+            | DdlCommand::DropSubscription(_, _)
             | DdlCommand::AlterName(_, _)
             | DdlCommand::AlterObjectOwner(_, _)
             | DdlCommand::AlterSetSchema(_, _)
@@ -186,8 +187,7 @@ impl DdlCommand {
             | DdlCommand::CreateSourceWithoutStreamingJob(_)
             | DdlCommand::ReplaceTable(_)
             | DdlCommand::AlterSourceColumn(_)
-            | DdlCommand::CreateSubscription(_)
-            | DdlCommand::DropSubscription(_, _) => false,
+            | DdlCommand::CreateSubscription(_) => false,
         }
     }
 }