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 <swa...@hortonworks.com> Authored: Tue Oct 27 14:07:17 2015 -0700 Committer: Siddharth Wagle <swa...@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);