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); }