diff --git a/src/mito2/src/read/seq_scan.rs b/src/mito2/src/read/seq_scan.rs index 5737b2267b..5281055b37 100644 --- a/src/mito2/src/read/seq_scan.rs +++ b/src/mito2/src/read/seq_scan.rs @@ -211,6 +211,8 @@ impl SeqScan { /// Builds a [BoxedBatchReader] that can scan memtables and SSTs in parallel. async fn build_parallel_reader(&self) -> Result { + debug!("Build parallel reader, parallelism: {}", self.parallelism); + assert!(self.parallelism > 1); let semaphore = Arc::new(Semaphore::new(self.parallelism));