You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by sw...@apache.org on 2015/10/27 22:07:41 UTC
ambari git commit: AMBARI-13585. Flume metrics do not match up with
data being processed by storm. (Aravindan Vijayan via swagle)
Repository: ambari
Updated Branches:
refs/heads/branch-2.1 1d50022db -> 663263110
AMBARI-13585. Flume metrics do not match up with data being processed by storm. (Aravindan Vijayan via swagle)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/66326311
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/66326311
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/66326311
Branch: refs/heads/branch-2.1
Commit: 6632631102b3f113ea26f405bdb858d07adb54e8
Parents: 1d50022
Author: Siddharth Wagle <sw...@hortonworks.com>
Authored: Tue Oct 27 14:07:17 2015 -0700
Committer: Siddharth Wagle <sw...@hortonworks.com>
Committed: Tue Oct 27 14:07:17 2015 -0700
----------------------------------------------------------------------
.../metrics/timeline/HBaseTimelineMetricStore.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/66326311/ambari-metrics/ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/HBaseTimelineMetricStore.java
----------------------------------------------------------------------
diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/HBaseTimelineMetricStore.java b/ambari-metrics/ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/HBaseTimelineMetricStore.java
index 21f193f..17df629 100644
--- a/ambari-metrics/ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/HBaseTimelineMetricStore.java
+++ b/ambari-metrics/ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/HBaseTimelineMetricStore.java
@@ -40,6 +40,7 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
+import java.util.concurrent.TimeUnit;
import static org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline.TimelineMetricConfiguration.USE_GROUPBY_AGGREGATOR_QUERIES;
@@ -191,7 +192,7 @@ public class HBaseTimelineMetricStore extends AbstractService implements Timelin
if (prevTime != null) {
step = currTime - prevTime;
- Double rate = currVal / step;
+ Double rate = currVal / TimeUnit.MILLISECONDS.toSeconds(step);
timeValueEntry.setValue(rate);
} else {
timeValueEntry.setValue(0.0);