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()) {