diff --git a/src/mito2/src/read/series_scan.rs b/src/mito2/src/read/series_scan.rs index 3de81b6d0b..6756e91dae 100644 --- a/src/mito2/src/read/series_scan.rs +++ b/src/mito2/src/read/series_scan.rs @@ -52,7 +52,7 @@ use crate::sst::parquet::flat_format::primary_key_column_index; use crate::sst::parquet::format::PrimaryKeyArray; /// 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>>>;