From 4eb7fdc20ce8bec8eba1b17c389b1ad803e68509 Mon Sep 17 00:00:00 2001
From: evenyag <realevenyag@gmail.com>
Date: Wed, 29 Nov 2023 19:43:34 +0800
Subject: [PATCH] feat: enlarge channel size

---
 src/mito2/src/read/seq_scan.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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<Semaphore>) -> 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