rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-26 18:00:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: enlarge channel size

Browse Source
This commit is contained in:
evenyag
2023-11-29 19:43:34 +08:00
parent cb7ed6ad58
commit 4eb7fdc20c
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/mito2/src/read/seq_scan.rs
View File

@@ -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