From dfcddcc5c0f0d638b0b70ec089ed0cee195d30c4 Mon Sep 17 00:00:00 2001
From: Noel Kwan <noelkwan1998@gmail.com>
Date: Mon, 28 Oct 2024 15:42:59 +0800
Subject: [PATCH] fix warn

---
 src/batch/src/executor/mysql_query.rs | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/src/batch/src/executor/mysql_query.rs b/src/batch/src/executor/mysql_query.rs
index d06009cddbb46..296afa0b1e62b 100644
--- a/src/batch/src/executor/mysql_query.rs
+++ b/src/batch/src/executor/mysql_query.rs
@@ -12,24 +12,23 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use anyhow::{anyhow, Context};
+use anyhow::Context;
 use futures_async_stream::try_stream;
 use futures_util::stream::StreamExt;
 use mysql_async::prelude::*;
 use risingwave_common::catalog::{Field, Schema};
 use risingwave_common::row::OwnedRow;
-use risingwave_common::types::{DataType, Datum, Decimal, ScalarImpl};
+use risingwave_common::types::{DataType, Datum, ScalarImpl};
 use risingwave_common::util::chunk_coalesce::DataChunkBuilder;
 use risingwave_pb::batch_plan::plan_node::NodeBody;
 use rust_decimal::Decimal as RustDecimal;
-use thiserror_ext::AsReport;
 use {chrono, mysql_async};
 
 use crate::error::BatchError;
 use crate::executor::{BoxedExecutor, BoxedExecutorBuilder, DataChunk, Executor, ExecutorBuilder};
 use crate::task::BatchTaskContext;
 
-/// `MySqlQuery` executor. Runs a query against a MySql database.
+/// `MySqlQuery` executor. Runs a query against a `MySql` database.
 pub struct MySqlQueryExecutor {
     schema: Schema,
     host: String,
@@ -161,7 +160,7 @@ impl MySqlQueryExecutor {
         // deserialize the rows
         #[for_await]
         for row in row_stream {
-            let mut row = row?;
+            let row = row?;
             let owned_row = mysql_row_to_owned_row(row, &self.schema)?;
             if let Some(chunk) = builder.append_one_row(owned_row) {
                 yield chunk;