diff --git a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/ipc/MetricsHBaseServerSourceFactory.java b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/ipc/MetricsHBaseServerSourceFactory.java index 4ad9f33..657f7ea 100644 --- a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/ipc/MetricsHBaseServerSourceFactory.java +++ b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/ipc/MetricsHBaseServerSourceFactory.java @@ -19,7 +19,13 @@ package org.apache.hadoop.hbase.ipc; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; + public abstract class MetricsHBaseServerSourceFactory { + + private static final Log LOG = LogFactory.getLog(MetricsHBaseServerSourceFactory.class); + /** * The name of the metrics */ @@ -47,9 +53,10 @@ * @return The Camel Cased context name. */ protected static String createContextName(String serverName) { - if (serverName.contains("HMaster")) { + LOG.debug("Received serverName: " + serverName); + if (serverName.contains("HMaster") || serverName.contains("master")) { return "Master"; - } else if (serverName.contains("HRegion")) { + } else if (serverName.contains("HRegion") || serverName.contains("regionserver")) { return "RegionServer"; } return "IPC";