diff --git a/src/mito2/src/read/series_scan.rs b/src/mito2/src/read/series_scan.rs index 63080bb146..572c7583a8 100644 --- a/src/mito2/src/read/series_scan.rs +++ b/src/mito2/src/read/series_scan.rs @@ -48,7 +48,7 @@ use crate::read::stream::{ConvertBatchStream, ScanBatch, ScanBatchStream}; use crate::read::{Batch, ScannerMetrics}; /// Timeout to send a batch to a sender. -const SEND_TIMEOUT: Duration = Duration::from_millis(10); +const SEND_TIMEOUT: Duration = Duration::from_micros(100); /// List of receivers. type ReceiverList = Vec>>>;