From c72b5194f1cff7818651a3cb1525c9868a35b433 Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Wed, 20 May 2026 04:45:26 +0000 Subject: [PATCH] refactor: remove magic bool and clarify compaction pre-read warning Agent-Logs-Url: https://github.com/GreptimeTeam/greptimedb/sessions/d0dc5df7-0d37-4ed0-bfb9-a796fc8025af Co-authored-by: MichaelScofield <990479+MichaelScofield@users.noreply.github.com> --- src/mito2/src/compaction.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/mito2/src/compaction.rs b/src/mito2/src/compaction.rs index 78d28cceb8..dbd1739716 100644 --- a/src/mito2/src/compaction.rs +++ b/src/mito2/src/compaction.rs @@ -1006,7 +1006,7 @@ impl CompactionSstReaderBuilder<'_> { /// for compaction. The schema of the [FlatSource] is unified. async fn build_flat_sst_reader(self) -> Result { let scan_input = self.build_scan_input().await?.with_compaction(true); - let schema = scan_input.mapper.input_arrow_schema(true); + let schema = scan_input.mapper.input_arrow_schema(scan_input.compaction); let stream = SeqScan::new(scan_input) .build_flat_reader_for_compaction() @@ -1097,7 +1097,7 @@ impl CompactionSstReaderBuilder<'_> { Err(e) if e.is_object_not_found() => { warn!( e; - "Input SST file does not exist during compaction metadata pre-read, skipping it, region_id: {}, file: {}", + "Input SST file does not exist during compaction metadata pre-read, skipping it (this can happen during concurrent deletion/cleanup), region_id: {}, file: {}", file_handle.region_id(), file_handle.file_id() );