From 294c4c5c9ae47fe1eb150d44e2b7e138c3e76ed5 Mon Sep 17 00:00:00 2001
From: discord9 <discord9@163.com>
Date: Thu, 26 Dec 2024 14:32:20 +0800
Subject: [PATCH] chore: after rebase

---
 src/flow/src/error.rs  |  4 ++--
 src/flow/src/server.rs | 11 +++--------
 2 files changed, 5 insertions(+), 10 deletions(-)

diff --git a/src/flow/src/error.rs b/src/flow/src/error.rs
index 11a79a050b21..e78e0d6fa33c 100644
--- a/src/flow/src/error.rs
+++ b/src/flow/src/error.rs
@@ -20,9 +20,9 @@ use common_error::ext::BoxedError;
 use common_error::{define_into_tonic_status, from_err_code_msg_to_header};
 use common_macro::stack_trace_debug;
 use common_telemetry::common_error::ext::ErrorExt;
-use common_telemetry::common_error::status_code::StatusCode;\
-use tonic::metadata::MetadataMap;
+use common_telemetry::common_error::status_code::StatusCode;
 use snafu::{Location, ResultExt, Snafu};
+use tonic::metadata::MetadataMap;
 
 use crate::adapter::FlowId;
 use crate::expr::EvalError;
diff --git a/src/flow/src/server.rs b/src/flow/src/server.rs
index c413201183e8..4e01958b1c4f 100644
--- a/src/flow/src/server.rs
+++ b/src/flow/src/server.rs
@@ -55,10 +55,9 @@ use tonic::{Request, Response, Status};
 
 use crate::adapter::{CreateFlowArgs, FlowWorkerManagerRef};
 use crate::error::{
-    to_status_with_last_err, CacheRequiredSnafu, ExternalSnafu, FlowNotFoundSnafu, ListFlowsSnafu,
-    ParseAddrSnafu, ShutdownServerSnafu, StartServerSnafu, UnexpectedSnafu,
-    FindTableRouteSnafu, 
-    RequestQuerySnafu,
+    to_status_with_last_err, CacheRequiredSnafu, ExternalSnafu, FindTableRouteSnafu,
+    FlowNotFoundSnafu, ListFlowsSnafu, ParseAddrSnafu, RequestQuerySnafu, ShutdownServerSnafu,
+    StartServerSnafu, UnexpectedSnafu,
 };
 use crate::heartbeat::HeartbeatTask;
 use crate::metrics::{METRIC_FLOW_PROCESSING_TIME, METRIC_FLOW_ROWS};
@@ -583,10 +582,6 @@ impl FrontendInvoker {
             .map_err(BoxedError::new)
             .context(common_frontend::error::ExternalSnafu)
     }
-
-    pub fn statement_executor(&self) -> Arc<StatementExecutor> {
-        self.statement_executor.clone()
-    }
 }
 
 /// get all flow ids in this flownode