Repository: accumulo Updated Branches: refs/heads/1.7 e7436958f -> 7f1243373
ACCUMULO-4334 JMX Ingest returns double Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/67605d72 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/67605d72 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/67605d72 Branch: refs/heads/1.7 Commit: 67605d72835706c38e2c70a29895a92be4d75e24 Parents: 63e834e Author: Dylan Hutchison <dhutc...@cs.washington.edu> Authored: Wed Jun 8 18:46:16 2016 -0700 Committer: Dylan Hutchison <dhutc...@cs.washington.edu> Committed: Wed Jun 8 18:52:26 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/accumulo/tserver/TabletServer.java | 4 ++-- .../org/apache/accumulo/tserver/metrics/TabletServerMBean.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/67605d72/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java index 43ed136..955c365 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java @@ -3830,13 +3830,13 @@ public class TabletServer extends AbstractMetricsImpl implements org.apache.accu } @Override - public long getIngest() { + public double getIngest() { if (this.isEnabled()) { double result = 0; for (Tablet tablet : Collections.unmodifiableCollection(onlineTablets.values())) { result += tablet.ingestRate(); } - return (long) result; + return result; } return 0; } http://git-wip-us.apache.org/repos/asf/accumulo/blob/67605d72/server/tserver/src/main/java/org/apache/accumulo/tserver/metrics/TabletServerMBean.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/metrics/TabletServerMBean.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/metrics/TabletServerMBean.java index dc35c28..cf36eb0 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/metrics/TabletServerMBean.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/metrics/TabletServerMBean.java @@ -38,7 +38,7 @@ public interface TabletServerMBean { long getQueries(); - long getIngest(); + double getIngest(); long getTotalMinorCompactions();
