diff --git a/src/common/meta/src/ddl/create_flow/metadata.rs b/src/common/meta/src/ddl/create_flow/metadata.rs
index b9250054edd3..c7298513bd5b 100644
--- a/src/common/meta/src/ddl/create_flow/metadata.rs
+++ b/src/common/meta/src/ddl/create_flow/metadata.rs
@@ -21,7 +21,7 @@ use crate::key::table_name::TableNameKey;
 impl CreateFlowProcedure {
     /// Allocates the [FlowTaskId].
     pub(crate) async fn allocate_flow_task_id(&mut self) -> Result<()> {
-        //TODO(weny, ruihang): We doesn't support the partitions. It's always be 1, now.
+        //TODO(weny, ruihang): We don't support the partitions. It's always be 1, now.
         let partitions = 1;
         let (flow_task_id, peers) = self
             .context
@@ -37,7 +37,6 @@ impl CreateFlowProcedure {
     /// Collects source table ids
     pub(crate) async fn collect_source_tables(&mut self) -> Result<()> {
         // Ensures all source tables exist.
-
         let keys = self
             .data
             .task
diff --git a/src/common/meta/src/error.rs b/src/common/meta/src/error.rs
index 29dfcfc0757e..40d5070c3bb3 100644
--- a/src/common/meta/src/error.rs
+++ b/src/common/meta/src/error.rs
@@ -241,7 +241,7 @@ pub enum Error {
         location: Location,
     },
 
-    #[snafu(display("Task already exists, task: {}", task_name,))]
+    #[snafu(display("Task already exists: {}", task_name))]
     TaskAlreadyExists {
         task_name: String,
         location: Location,