From 2cf076b51ff9ffef1385c144713343cb9b621fcc Mon Sep 17 00:00:00 2001
From: Ruihang Xia <waynestxia@gmail.com>
Date: Sun, 28 Apr 2024 18:36:20 +0800
Subject: [PATCH] rename symbol

Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
---
 src/common/meta/src/rpc/ddl.rs | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/common/meta/src/rpc/ddl.rs b/src/common/meta/src/rpc/ddl.rs
index a7e14161ecc6..ada56a251c64 100644
--- a/src/common/meta/src/rpc/ddl.rs
+++ b/src/common/meta/src/rpc/ddl.rs
@@ -724,7 +724,7 @@ impl TryFrom<DropDatabaseTask> for PbDropDatabaseTask {
 }
 
 /// Create flow task
-pub struct CreateFlowTask {
+pub struct CreateFlow {
     pub catalog_name: String,
     pub task_name: String,
     pub source_table_names: Vec<TableName>,
@@ -737,7 +737,7 @@ pub struct CreateFlowTask {
     pub options: HashMap<String, String>,
 }
 
-impl TryFrom<PbCreateFlowTask> for CreateFlowTask {
+impl TryFrom<PbCreateFlowTask> for CreateFlow {
     type Error = error::Error;
 
     fn try_from(pb: PbCreateFlowTask) -> Result<Self> {
@@ -756,7 +756,7 @@ impl TryFrom<PbCreateFlowTask> for CreateFlowTask {
             err_msg: "expected create_flow_task",
         })?;
 
-        Ok(CreateFlowTask {
+        Ok(CreateFlow {
             catalog_name,
             task_name,
             source_table_names: source_table_names.into_iter().map(Into::into).collect(),
@@ -775,9 +775,9 @@ impl TryFrom<PbCreateFlowTask> for CreateFlowTask {
     }
 }
 
-impl From<CreateFlowTask> for PbCreateFlowTask {
+impl From<CreateFlow> for PbCreateFlowTask {
     fn from(
-        CreateFlowTask {
+        CreateFlow {
             catalog_name,
             task_name,
             source_table_names,
@@ -788,7 +788,7 @@ impl From<CreateFlowTask> for PbCreateFlowTask {
             comment,
             sql,
             options,
-        }: CreateFlowTask,
+        }: CreateFlow,
     ) -> Self {
         PbCreateFlowTask {
             create_flow_task: Some(CreateFlowTaskExpr {