From 3e5bbdf71e6ff9435b44270a41de648a26ed30ae Mon Sep 17 00:00:00 2001 From: evenyag Date: Tue, 5 Nov 2024 15:16:53 +0800 Subject: [PATCH] feat: enable batch checker --- src/mito2/src/read.rs | 4 ++-- src/mito2/src/read/unordered_scan.rs | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/mito2/src/read.rs b/src/mito2/src/read.rs index d8ac5ce46b..4d7255f34d 100644 --- a/src/mito2/src/read.rs +++ b/src/mito2/src/read.rs @@ -572,7 +572,7 @@ impl Batch { } /// A struct to check the batch is monotonic. -#[cfg(debug_assertions)] +// #[cfg(debug_assertions)] #[derive(Default)] pub(crate) struct BatchChecker { last_batch: Option, @@ -580,7 +580,7 @@ pub(crate) struct BatchChecker { end: Option, } -#[cfg(debug_assertions)] +// #[cfg(debug_assertions)] impl BatchChecker { /// Attaches the given start timestamp to the checker. pub(crate) fn with_start(mut self, start: Option) -> Self { diff --git a/src/mito2/src/read/unordered_scan.rs b/src/mito2/src/read/unordered_scan.rs index d7663349e0..7ca08e2fd5 100644 --- a/src/mito2/src/read/unordered_scan.rs +++ b/src/mito2/src/read/unordered_scan.rs @@ -145,7 +145,7 @@ impl UnorderedScan { partition, part_range, ); - #[cfg(debug_assertions)] + // #[cfg(debug_assertions)] let mut checker = crate::read::BatchChecker::default() .with_start(Some(part_range.start)) .with_end(Some(part_range.end)); @@ -168,7 +168,7 @@ impl UnorderedScan { continue; } - #[cfg(debug_assertions)] + // #[cfg(debug_assertions)] checker.ensure_part_range_batch( "UnorderedScan", stream_ctx.input.mapper.metadata().region_id,