chore: add debug info to see how many concurrent partitions being compacted in each cycle (#4772)

Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com>
pull/24376/head
Nga Tran 2022-06-02 11:19:08 -04:00 committed by GitHub
parent 1f87dde95f
commit 79895b995c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 0 deletions

View File

@ -227,6 +227,10 @@ async fn run_compactor(compactor: Arc<Compactor>, shutdown: CancellationToken) {
} }
let compactions_run = handles.len(); 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; let _ = futures::future::join_all(handles).await;