You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2014/09/27 05:09:02 UTC
git commit: no need to fetch throughput if no compactions
Repository: cassandra
Updated Branches:
refs/heads/trunk a639379ba -> 04f0d412b
no need to fetch throughput if no compactions
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/04f0d412
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/04f0d412
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/04f0d412
Branch: refs/heads/trunk
Commit: 04f0d412b271af0dbe7665976a4165dfd0dfcb66
Parents: a639379
Author: Dave Brosius <db...@mebigfatguy.com>
Authored: Fri Sep 26 23:08:30 2014 -0400
Committer: Dave Brosius <db...@mebigfatguy.com>
Committed: Fri Sep 26 23:08:30 2014 -0400
----------------------------------------------------------------------
src/java/org/apache/cassandra/tools/NodeTool.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/04f0d412/src/java/org/apache/cassandra/tools/NodeTool.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/tools/NodeTool.java b/src/java/org/apache/cassandra/tools/NodeTool.java
index e768d47..217e47f 100644
--- a/src/java/org/apache/cassandra/tools/NodeTool.java
+++ b/src/java/org/apache/cassandra/tools/NodeTool.java
@@ -1171,13 +1171,13 @@ public class NodeTool
@Override
public void execute(NodeProbe probe)
{
- int compactionThroughput = probe.getCompactionThroughput();
CompactionManagerMBean cm = probe.getCompactionManagerProxy();
System.out.println("pending tasks: " + probe.getCompactionMetric("PendingTasks"));
long remainingBytes = 0;
List<Map<String, String>> compactions = cm.getCompactions();
if (!compactions.isEmpty())
{
+ int compactionThroughput = probe.getCompactionThroughput();
List<String[]> lines = new ArrayList<>();
int[] columnSizes = new int[] { 0, 0, 0, 0, 0, 0, 0 };