diff --git a/src/common/recordbatch/src/adapter.rs b/src/common/recordbatch/src/adapter.rs index 24d5c2af4a..c54f7511c1 100644 --- a/src/common/recordbatch/src/adapter.rs +++ b/src/common/recordbatch/src/adapter.rs @@ -116,6 +116,7 @@ impl Stream for DfRecordBatchStreamAdapter { pub struct RecordBatchStreamAdapter { schema: SchemaRef, stream: DfSendableRecordBatchStream, + #[allow(dead_code)] metrics: Option, } @@ -154,12 +155,12 @@ impl Stream for RecordBatchStreamAdapter { type Item = Result; fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> { - let timer = self - .metrics - .as_ref() - .map(|m| m.elapsed_compute().clone()) - .unwrap_or_default(); - let _guard = timer.timer(); + // let timer = self + // .metrics + // .as_ref() + // .map(|m| m.elapsed_compute().clone()) + // .unwrap_or_default(); + // let _guard = timer.timer(); match Pin::new(&mut self.stream).poll_next(cx) { Poll::Pending => Poll::Pending, Poll::Ready(Some(df_record_batch)) => {