chore: minor update

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(),

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];