You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by av...@apache.org on 2016/10/20 23:29:50 UTC
ambari git commit: AMBARI-18655 : Metric level hadoop metrics2 filter
is incompatible with AMS HadoopTimelineMetricsSink. (avijayan)
Repository: ambari
Updated Branches:
refs/heads/trunk 5256a7890 -> dd0cc32b7
AMBARI-18655 : Metric level hadoop metrics2 filter is incompatible with AMS HadoopTimelineMetricsSink. (avijayan)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/dd0cc32b
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/dd0cc32b
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/dd0cc32b
Branch: refs/heads/trunk
Commit: dd0cc32b71988add58d6e796dc77722a937c28b1
Parents: 5256a78
Author: Aravindan Vijayan <av...@hortonworks.com>
Authored: Thu Oct 20 16:29:35 2016 -0700
Committer: Aravindan Vijayan <av...@hortonworks.com>
Committed: Thu Oct 20 16:29:35 2016 -0700
----------------------------------------------------------------------
.../metrics2/sink/timeline/HadoopTimelineMetricsSink.java | 7 +------
1 file changed, 1 insertion(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/dd0cc32b/ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java
----------------------------------------------------------------------
diff --git a/ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java b/ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java
index d81187e..2bfc6db 100644
--- a/ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java
+++ b/ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java
@@ -298,19 +298,14 @@ public class HadoopTimelineMetricsSink extends AbstractTimelineMetricsSink imple
}
int sbBaseLen = sb.length();
-
- Collection<AbstractMetric> metrics = (Collection<AbstractMetric>) record.metrics();
-
List<TimelineMetric> metricList = new ArrayList<TimelineMetric>();
Map<String, String> metadata = null;
if (skipAggregation) {
metadata = Collections.singletonMap("skipAggregation", "true");
}
-
-
long startTime = record.timestamp();
- for (AbstractMetric metric : metrics) {
+ for (AbstractMetric metric : record.metrics()) {
sb.append(metric.name());
String name = sb.toString();
Number value = metric.value();