Преглед на файлове

AMBARI-8594. Push AMS Hbase metrics with its own appid. Unit test fix. (swagle)

Siddharth Wagle преди 10 години
родител
ревизия
cff01d6ffd

+ 1 - 1
ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java

@@ -110,7 +110,7 @@ public class HadoopTimelineMetricsSink extends AbstractTimelineMetricsSink imple
   private String getServiceName(SubsetConfiguration conf) {
     String serviceNamePrefix = conf.getString(SERVICE_NAME_PREFIX, "");
     return serviceNamePrefix.isEmpty() ? getFirstConfigPrefix(conf) :
-      serviceNamePrefix + "-" + getFirstConfigPrefix(conf);
+           serviceNamePrefix + "-" + getFirstConfigPrefix(conf);
   }
 
   private String getFirstConfigPrefix(SubsetConfiguration conf) {

+ 1 - 0
ambari-metrics/ambari-metrics-hadoop-sink/src/test/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSinkTest.java

@@ -50,6 +50,7 @@ public class HadoopTimelineMetricsSinkTest {
     expect(conf.getParent()).andReturn(null).anyTimes();
     expect(conf.getPrefix()).andReturn("service").anyTimes();
     expect(conf.getString(eq(COLLECTOR_HOST_PROPERTY))).andReturn("localhost:63188").anyTimes();
+    expect(conf.getString(eq("serviceName-prefix"), eq(""))).andReturn("").anyTimes();
 
     expect(conf.getInt(eq(MAX_METRIC_ROW_CACHE_SIZE), anyInt())).andReturn(10).anyTimes();
     expect(conf.getInt(eq(METRICS_SEND_INTERVAL), anyInt())).andReturn(1000).anyTimes();