diff --git a/compactor/src/handler.rs b/compactor/src/handler.rs index 2ad880893c..66f12faab4 100644 --- a/compactor/src/handler.rs +++ b/compactor/src/handler.rs @@ -227,6 +227,10 @@ async fn run_compactor(compactor: Arc, shutdown: CancellationToken) { } let compactions_run = handles.len(); + debug!( + ?compactions_run, + "Number of concurrent partitions are being compacted in this cycle" + ); let _ = futures::future::join_all(handles).await;