From 56952095a8d49986016e23f44a21bd8fda579628 Mon Sep 17 00:00:00 2001 From: evenyag Date: Tue, 3 Dec 2024 19:26:10 +0800 Subject: [PATCH] fix: parallel scan on multiple sources --- src/mito2/src/read/scan_region.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/mito2/src/read/scan_region.rs b/src/mito2/src/read/scan_region.rs index 2624f29547..025a4333bb 100644 --- a/src/mito2/src/read/scan_region.rs +++ b/src/mito2/src/read/scan_region.rs @@ -621,7 +621,7 @@ impl ScanInput { sources: Vec, semaphore: Arc, ) -> Result> { - if sources.len() > 1 { + if sources.len() <= 1 { return Ok(sources); }