fix(storage): fix pre_process_task

risingwavelabs · Dec 22, 2022 · 5a73c46 · 5a73c46
1 parent 8815279
commit 5a73c46
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/storage/src/hummock/compactor/mod.rs b/src/storage/src/hummock/compactor/mod.rs
@@ -379,7 +379,7 @@ impl Compactor {
 
     pub fn pre_process_task(task: &mut Task, workload: &CompactorWorkload) {
         const CPU_THRESHOLD: u32 = 80;
-        if let Task::CompactTask(mut compact_task) = task.clone() {
+        if let Task::CompactTask(compact_task) = task {
             if workload.cpu > CPU_THRESHOLD && compact_task.input_ssts[0].level_idx != 0 {
                 compact_task.set_task_status(TaskStatus::ManualCanceled);
             }