mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-05-28 10:50:39 +00:00
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>
This commit is contained in:
committed by
GitHub
parent
97b3b18f32
commit
c72b5194f1
@@ -1006,7 +1006,7 @@ impl CompactionSstReaderBuilder<'_> {
|
||||
/// for compaction. The schema of the [FlatSource] is unified.
|
||||
async fn build_flat_sst_reader(self) -> Result<FlatSource> {
|
||||
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()
|
||||
);
|
||||
|
||||
Reference in New Issue
Block a user