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

chore: 128 channel size

Browse Source
This commit is contained in:
evenyag
2023-11-29 21:32:25 +08:00
parent 3c95b3bd44
commit fb96e3f68d
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

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