diff --git a/src/mito2/src/read/seq_scan.rs b/src/mito2/src/read/seq_scan.rs index c347bd81f1..5737b2267b 100644 --- a/src/mito2/src/read/seq_scan.rs +++ b/src/mito2/src/read/seq_scan.rs @@ -261,7 +261,7 @@ impl SeqScan { /// Scan the input source in another task. fn scan_source_in_background(mut input: Source, semaphore: Arc) -> BoxedBatchStream { - let (sender, receiver) = mpsc::channel(1); + let (sender, receiver) = mpsc::channel(64); tokio::spawn(async move { loop { // We release the permit before sending result to avoid the task waiting on