fix: wait for compaction task to finish (#1783)

This commit is contained in:
Lei, HUANG
2023-06-16 16:45:06 +08:00
committed by GitHub
parent 1eeb5b4330
commit 69854c07c5
3 changed files with 29 additions and 13 deletions
+1 -1
View File
@@ -354,7 +354,7 @@ impl Instance {
fn create_compaction_scheduler<S: LogStore>(opts: &DatanodeOptions) -> CompactionSchedulerRef<S> {
let picker = SimplePicker::default();
let config = SchedulerConfig::from(opts);
let handler = CompactionHandler::new(picker);
let handler = CompactionHandler { picker };
let scheduler = LocalScheduler::new(config, handler);
Arc::new(scheduler)
}