diff --git a/src/mito2/src/compaction/twcs.rs b/src/mito2/src/compaction/twcs.rs index 2aaafead05..f70d45a9b2 100644 --- a/src/mito2/src/compaction/twcs.rs +++ b/src/mito2/src/compaction/twcs.rs @@ -209,7 +209,7 @@ fn enforce_file_num(files: &[T], max_file_num: usize) -> Vec { files.iter().skip(min_idx).take(to_merge).cloned().collect() } -const MAX_FILE_SIZE: ReadableSize = ReadableSize::mb(512); +const MAX_FILE_SIZE: ReadableSize = ReadableSize::gb(1); impl Picker for TwcsPicker { fn pick(&self, compaction_region: &CompactionRegion) -> Option { @@ -310,6 +310,9 @@ fn assign_to_windows<'a>( let mut windows: HashMap = HashMap::new(); // Iterates all files and assign to time windows according to max timestamp for f in files { + if file.compacting() { + continue; + } let (_, end) = f.time_range(); let time_window = end .convert_to(TimeUnit::Second)