From 8c90f2e800bcd1bd53bd251e165066b25074188b Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Wed, 20 May 2026 04:46:03 +0000 Subject: [PATCH] docs: clarify flat input schema requirement in compaction reader 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 | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/mito2/src/compaction.rs b/src/mito2/src/compaction.rs index dbd1739716..7d4302cb74 100644 --- a/src/mito2/src/compaction.rs +++ b/src/mito2/src/compaction.rs @@ -1006,6 +1006,8 @@ 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); + // Compaction reads/writes flat SST batches (with internal columns), so this must use + // the flat input schema instead of the logical output schema. let schema = scan_input.mapper.input_arrow_schema(scan_input.compaction); let stream = SeqScan::new(scan_input)