From cfa69b6af001b2b95c35a8f2af4610e2e8dcb47f Mon Sep 17 00:00:00 2001
From: "chenmian.cm" <chenmian.cm@antfin.com>
Date: Mon, 25 Mar 2024 16:47:55 +0800
Subject: [PATCH] remove Arc

---
 src/analytic_engine/src/instance/wal_replayer.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/analytic_engine/src/instance/wal_replayer.rs b/src/analytic_engine/src/instance/wal_replayer.rs
index ec44ad7e49..6a996fe996 100644
--- a/src/analytic_engine/src/instance/wal_replayer.rs
+++ b/src/analytic_engine/src/instance/wal_replayer.rs
@@ -186,13 +186,13 @@ impl Replay for TableBasedReplay {
             batch_size: context.wal_replay_batch_size,
             ..Default::default()
         };
-        let read_ctx = &read_ctx;
 
         let mut tasks = futures::stream::iter(
             table_datas
                 .iter()
                 .map(|table_data| {
                     let table_id = table_data.id;
+                    let read_ctx = &read_ctx;
                     async move {
                         let ret = Self::recover_table_logs(context, table_data, read_ctx).await;
                         (table_id, ret)