diff --git a/src/mito2/src/read/seq_scan.rs b/src/mito2/src/read/seq_scan.rs index 3cec65b710..0d676fae18 100644 --- a/src/mito2/src/read/seq_scan.rs +++ b/src/mito2/src/read/seq_scan.rs @@ -274,7 +274,7 @@ impl SeqScan { stream_ctx.input.num_memtables(), stream_ctx.input.num_files(), )); - let mapper = stream_ctx.input.mapper.as_primary_key().context(UnexpectedSnafu { + let _mapper = stream_ctx.input.mapper.as_primary_key().context(UnexpectedSnafu { reason: "Unexpected format", })?; // Scans each part. @@ -312,7 +312,7 @@ impl SeqScan { #[cfg(debug_assertions)] checker.ensure_part_range_batch( "SeqScan", - mapper.metadata().region_id, + _mapper.metadata().region_id, partition, part_range, &batch, diff --git a/src/mito2/src/read/unordered_scan.rs b/src/mito2/src/read/unordered_scan.rs index e9ac497962..70f5d89c4d 100644 --- a/src/mito2/src/read/unordered_scan.rs +++ b/src/mito2/src/read/unordered_scan.rs @@ -227,7 +227,7 @@ impl UnorderedScan { for part_range in part_ranges { let mut metrics = ScannerMetrics::default(); let mut fetch_start = Instant::now(); - let mapper = &stream_ctx.input.mapper; + let _mapper = &stream_ctx.input.mapper; #[cfg(debug_assertions)] let mut checker = crate::read::BatchChecker::default() .with_start(Some(part_range.start)) @@ -253,7 +253,7 @@ impl UnorderedScan { #[cfg(debug_assertions)] checker.ensure_part_range_batch( "UnorderedScan", - mapper.metadata().region_id, + _mapper.metadata().region_id, partition, part_range, &batch,