From 68d4e28d94a69bfa954a04c4e2fbdb75252db47b Mon Sep 17 00:00:00 2001 From: Jonathan Ellis Date: Thu, 26 Jan 2012 16:58:47 -0600 Subject: [PATCH] Log active compactions in StatusLogger patch by jbellis; reviewed by slebresne for CASSANDRA-3703 --- CHANGES.txt | 1 + src/java/org/apache/cassandra/utils/StatusLogger.java | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/CHANGES.txt b/CHANGES.txt index 2c7db7689d..7faf97f36a 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 1.0.8 + * Log active compactions in StatusLogger (CASSANDRA-3703) * Compute more accurate compaction score per level (CASSANDRA-3790) * Return InvalidRequest when using a keyspace that doesn't exist (CASSANDRA-3764) diff --git a/src/java/org/apache/cassandra/utils/StatusLogger.java b/src/java/org/apache/cassandra/utils/StatusLogger.java index 55453af311..fa67b458e5 100644 --- a/src/java/org/apache/cassandra/utils/StatusLogger.java +++ b/src/java/org/apache/cassandra/utils/StatusLogger.java @@ -66,8 +66,9 @@ public class StatusLogger poolName, threadPoolProxy.getActiveCount(), threadPoolProxy.getPendingTasks(), threadPoolProxy.getCurrentlyBlockedTasks())); } // one offs + CompactionManager cm = CompactionManager.instance; logger.info(String.format("%-25s%10s%10s", - "CompactionManager", "n/a", CompactionManager.instance.getPendingTasks())); + "CompactionManager", cm.getActiveCompactions(), cm.getPendingTasks())); int pendingCommands = 0; for (int n : MessagingService.instance().getCommandPendingTasks().values()) {