fix(compactor): fix the calculation of pending_pull_task_count (#16885)

risingwavelabs · May 29, 2024 · 82adba6 · 82adba6
1 parent 242990b
commit 82adba6
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
@@ -393,7 +393,7 @@ pub fn start_compactor(
                         let mut pending_pull_task_count = 0;
                         if pull_task_ack {
                             // TODO: Compute parallelism on meta side
-                            pending_pull_task_count = (max_task_parallelism - running_task_parallelism.load(Ordering::SeqCst)).max(max_pull_task_count);
+                            pending_pull_task_count = (max_task_parallelism - running_task_parallelism.load(Ordering::SeqCst)).min(max_pull_task_count);
 
                             if pending_pull_task_count > 0 {
                                 if let Err(e) = request_sender.send(SubscribeCompactionEventRequest {