remove Arc

apache · Mar 25, 2024 · 2ab5a75 · 2ab5a75
1 parent b1ff6b6
commit 2ab5a75
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/analytic_engine/src/instance/wal_replayer.rs b/src/analytic_engine/src/instance/wal_replayer.rs
@@ -182,19 +182,19 @@ impl Replay for TableBasedReplay {
         debug!("Replay wal logs on table mode, context:{context}, tables:{table_datas:?}",);
 
         let mut failed_tables = HashMap::new();
-        let read_ctx = Arc::new(ReadContext {
+        let read_ctx = ReadContext {
             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.clone();
                     async move {
-                        let ret = Self::recover_table_logs(context, table_data, &read_ctx).await;
+                        let ret = Self::recover_table_logs(context, table_data, read_ctx).await;
                         (table_id, ret)
                     }
                 })