From fb96e3f68ddcdaf43c704d596c323bca6bfbadb4 Mon Sep 17 00:00:00 2001
From: evenyag <realevenyag@gmail.com>
Date: Wed, 29 Nov 2023 21:32:25 +0800
Subject: [PATCH] chore: 128 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 984faab350..dbdf604e9a 100644
--- a/src/mito2/src/read/seq_scan.rs
+++ b/src/mito2/src/read/seq_scan.rs
@@ -270,7 +270,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(64);
+        let (sender, receiver) = mpsc::channel(128);
         tokio::spawn(async move {
             loop {
                 // We release the permit before sending result to avoid the task waiting on