diff --git a/src/common/recordbatch/src/adapter.rs b/src/common/recordbatch/src/adapter.rs
index 3494adb46c..24d5c2af4a 100644
--- a/src/common/recordbatch/src/adapter.rs
+++ b/src/common/recordbatch/src/adapter.rs
@@ -163,13 +163,6 @@ impl Stream for RecordBatchStreamAdapter {
         match Pin::new(&mut self.stream).poll_next(cx) {
             Poll::Pending => Poll::Pending,
             Poll::Ready(Some(df_record_batch)) => {
-                let timer = self
-                    .metrics
-                    .as_ref()
-                    .map(|m| m.elapsed_compute().clone())
-                    .unwrap_or_default();
-                let _guard = timer.timer();
-
                 let df_record_batch = df_record_batch.context(error::PollStreamSnafu)?;
                 Poll::Ready(Some(RecordBatch::try_from_df_record_batch(
                     self.schema(),
diff --git a/src/meta-srv/src/handler/keep_lease_handler.rs b/src/meta-srv/src/handler/keep_lease_handler.rs
index 60a93611be..24fa22134b 100644
--- a/src/meta-srv/src/handler/keep_lease_handler.rs
+++ b/src/meta-srv/src/handler/keep_lease_handler.rs
@@ -29,7 +29,7 @@ pub struct KeepLeaseHandler {
 
 impl KeepLeaseHandler {
     pub fn new(kv_store: KvStoreRef) -> Self {
-        let (tx, mut rx) = mpsc::channel(128);
+        let (tx, mut rx) = mpsc::channel(1024);
         common_runtime::spawn_bg(async move {
             while let Some(kv) = rx.recv().await {
                 let mut kvs = vec![kv];