ambari-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject ambari git commit: AMBARI-16968 Capture user based metrics for Namenode fair call queue. (dsen)
Date Tue, 31 May 2016 20:09:39 GMT
Repository: ambari
Updated Branches:
  refs/heads/branch-2.4 ecaef4142 -> 03d5f14ea


AMBARI-16968 Capture user based metrics for Namenode fair call queue. (dsen)


Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/03d5f14e
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/03d5f14e
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/03d5f14e

Branch: refs/heads/branch-2.4
Commit: 03d5f14ea764651ca085fdee4ebd57e472016d06
Parents: ecaef41
Author: Dmytro Sen <dsen@apache.org>
Authored: Tue May 31 23:08:18 2016 +0300
Committer: Dmytro Sen <dsen@apache.org>
Committed: Tue May 31 23:09:34 2016 +0300

----------------------------------------------------------------------
 .../metrics2/sink/timeline/HadoopTimelineMetricsSink.java   | 9 +++++++++
 1 file changed, 9 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/03d5f14e/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 8966978..0580088 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
@@ -198,6 +198,15 @@ public class HadoopTimelineMetricsSink extends AbstractTimelineMetricsSink
imple
       String contextName = record.context();
 
       StringBuilder sb = new StringBuilder();
+
+      // Transform ipc.8020 -> ipc.client,  ipc.8040 -> ipc.datanode, etc.
+      if (contextName.startsWith("ipc.")) {
+        String portNumber = contextName.replaceFirst("ipc.", "");
+        if (rpcPortSuffixes.containsKey(portNumber)) {
+          contextName = "ipc." + rpcPortSuffixes.get(portNumber);
+        }
+      }
+
       sb.append(contextName);
       sb.append('.');
       // Similar to GangliaContext adding processName to distinguish jvm


Mime
View raw message