Return-Path: X-Original-To: apmail-hbase-commits-archive@www.apache.org Delivered-To: apmail-hbase-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id F271210BD0 for ; Wed, 26 Feb 2014 01:02:46 +0000 (UTC) Received: (qmail 49227 invoked by uid 500); 26 Feb 2014 01:02:35 -0000 Delivered-To: apmail-hbase-commits-archive@hbase.apache.org Received: (qmail 49069 invoked by uid 500); 26 Feb 2014 01:02:33 -0000 Mailing-List: contact commits-help@hbase.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hbase.apache.org Delivered-To: mailing list commits@hbase.apache.org Received: (qmail 48997 invoked by uid 99); 26 Feb 2014 01:02:31 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 26 Feb 2014 01:02:31 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 26 Feb 2014 01:02:27 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id DFE4923889F1; Wed, 26 Feb 2014 01:02:05 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1571888 - in /hbase/branches/0.96: hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/ hbase-hadoop1-compat/src/main/java/org/apache/hadoop/hbase/master/ hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/master/ hbas... Date: Wed, 26 Feb 2014 01:02:05 -0000 To: commits@hbase.apache.org From: jmhsieh@apache.org X-Mailer: svnmailer-1.0.9 Message-Id: <20140226010205.DFE4923889F1@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: jmhsieh Date: Wed Feb 26 01:02:05 2014 New Revision: 1571888 URL: http://svn.apache.org/r1571888 Log: HBASE-10436 restore regionserver lists removed from hbase 0.96.0 jmx Modified: hbase/branches/0.96/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSource.java hbase/branches/0.96/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java hbase/branches/0.96/hbase-hadoop1-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSourceImpl.java hbase/branches/0.96/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSourceImpl.java hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapperImpl.java hbase/branches/0.96/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMasterMetricsWrapper.java Modified: hbase/branches/0.96/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSource.java URL: http://svn.apache.org/viewvc/hbase/branches/0.96/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSource.java?rev=1571888&r1=1571887&r2=1571888&view=diff ============================================================================== --- hbase/branches/0.96/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSource.java (original) +++ hbase/branches/0.96/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSource.java Wed Feb 26 01:02:05 2014 @@ -49,6 +49,8 @@ public interface MetricsMasterSource ext String MASTER_ACTIVE_TIME_NAME = "masterActiveTime"; String MASTER_START_TIME_NAME = "masterStartTime"; String AVERAGE_LOAD_NAME = "averageLoad"; + String LIVE_REGION_SERVERS_NAME = "liveRegionServers"; + String DEAD_REGION_SERVERS_NAME = "deadRegionServers"; String NUM_REGION_SERVERS_NAME = "numRegionServers"; String NUM_DEAD_REGION_SERVERS_NAME = "numDeadRegionServers"; String ZOOKEEPER_QUORUM_NAME = "zookeeperQuorum"; @@ -61,7 +63,9 @@ public interface MetricsMasterSource ext String MASTER_ACTIVE_TIME_DESC = "Master Active Time"; String MASTER_START_TIME_DESC = "Master Start Time"; String AVERAGE_LOAD_DESC = "AverageLoad"; + String LIVE_REGION_SERVERS_DESC = "Names of live RegionServers"; String NUMBER_OF_REGION_SERVERS_DESC = "Number of RegionServers"; + String DEAD_REGION_SERVERS_DESC = "Names of dead RegionServers"; String NUMBER_OF_DEAD_REGION_SERVERS_DESC = "Number of dead RegionServers"; String ZOOKEEPER_QUORUM_DESC = "Zookeeper Quorum"; String SERVER_NAME_DESC = "Server Name"; Modified: hbase/branches/0.96/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java URL: http://svn.apache.org/viewvc/hbase/branches/0.96/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java?rev=1571888&r1=1571887&r2=1571888&view=diff ============================================================================== --- hbase/branches/0.96/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java (original) +++ hbase/branches/0.96/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java Wed Feb 26 01:02:05 2014 @@ -83,12 +83,28 @@ public interface MetricsMasterWrapper { * * @return Live region servers */ - int getRegionServers(); + String getRegionServers(); + + /** + * Get the number of live region servers + * + * @return number of Live region servers + */ + + int getNumRegionServers(); /** * Get the dead region servers * * @return Dead region Servers */ - int getDeadRegionServers(); + String getDeadRegionServers(); + + /** + * Get the number of dead region servers + * + * @return number of Dead region Servers + */ + int getNumDeadRegionServers(); + } Modified: hbase/branches/0.96/hbase-hadoop1-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSourceImpl.java URL: http://svn.apache.org/viewvc/hbase/branches/0.96/hbase-hadoop1-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSourceImpl.java?rev=1571888&r1=1571887&r2=1571888&view=diff ============================================================================== --- hbase/branches/0.96/hbase-hadoop1-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSourceImpl.java (original) +++ hbase/branches/0.96/hbase-hadoop1-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSourceImpl.java Wed Feb 26 01:02:05 2014 @@ -18,26 +18,21 @@ package org.apache.hadoop.hbase.master; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; +import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.hbase.metrics.BaseSourceImpl; import org.apache.hadoop.metrics2.MetricsBuilder; import org.apache.hadoop.metrics2.MetricsRecordBuilder; import org.apache.hadoop.metrics2.lib.MetricMutableCounterLong; -import org.apache.hadoop.metrics2.lib.MetricMutableGaugeLong; -import org.apache.hadoop.metrics2.lib.MetricMutableHistogram; -import org.apache.hadoop.metrics2.lib.MetricMutableStat; /** * Hadoop1 implementation of MetricsMasterSource. * * Implements BaseSource through BaseSourceImpl, following the pattern */ +@InterfaceAudience.Private public class MetricsMasterSourceImpl extends BaseSourceImpl implements MetricsMasterSource { - private static final Log LOG = LogFactory.getLog(MetricsMasterSourceImpl.class.getName()); - private final MetricsMasterWrapper masterWrapper; private MetricMutableCounterLong clusterRequestsCounter; @@ -85,11 +80,15 @@ public class MetricsMasterSourceImpl .addGauge(MASTER_START_TIME_NAME, MASTER_START_TIME_DESC, masterWrapper.getStartTime()) .addGauge(AVERAGE_LOAD_NAME, AVERAGE_LOAD_DESC, masterWrapper.getAverageLoad()) + .tag(LIVE_REGION_SERVERS_NAME, LIVE_REGION_SERVERS_DESC, + masterWrapper.getRegionServers()) .addGauge(NUM_REGION_SERVERS_NAME, - NUMBER_OF_REGION_SERVERS_DESC, masterWrapper.getRegionServers()) + NUMBER_OF_REGION_SERVERS_DESC, masterWrapper.getNumRegionServers()) + .tag(DEAD_REGION_SERVERS_NAME, DEAD_REGION_SERVERS_DESC, + masterWrapper.getDeadRegionServers()) .addGauge(NUM_DEAD_REGION_SERVERS_NAME, NUMBER_OF_DEAD_REGION_SERVERS_DESC, - masterWrapper.getDeadRegionServers()) + masterWrapper.getNumDeadRegionServers()) .tag(ZOOKEEPER_QUORUM_NAME, ZOOKEEPER_QUORUM_DESC, masterWrapper.getZookeeperQuorum()) .tag(SERVER_NAME_NAME, SERVER_NAME_DESC, masterWrapper.getServerName()) .tag(CLUSTER_ID_NAME, CLUSTER_ID_DESC, masterWrapper.getClusterId()) Modified: hbase/branches/0.96/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSourceImpl.java URL: http://svn.apache.org/viewvc/hbase/branches/0.96/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSourceImpl.java?rev=1571888&r1=1571887&r2=1571888&view=diff ============================================================================== --- hbase/branches/0.96/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSourceImpl.java (original) +++ hbase/branches/0.96/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterSourceImpl.java Wed Feb 26 01:02:05 2014 @@ -80,11 +80,15 @@ public class MetricsMasterSourceImpl MASTER_START_TIME_DESC), masterWrapper.getStartTime()) .addGauge(Interns.info(AVERAGE_LOAD_NAME, AVERAGE_LOAD_DESC), masterWrapper.getAverageLoad()) + .tag(Interns.info(LIVE_REGION_SERVERS_NAME, LIVE_REGION_SERVERS_DESC), + masterWrapper.getRegionServers()) .addGauge(Interns.info(NUM_REGION_SERVERS_NAME, - NUMBER_OF_REGION_SERVERS_DESC), masterWrapper.getRegionServers()) + NUMBER_OF_REGION_SERVERS_DESC), masterWrapper.getNumRegionServers()) + .tag(Interns.info(DEAD_REGION_SERVERS_NAME, DEAD_REGION_SERVERS_DESC), + masterWrapper.getDeadRegionServers()) .addGauge(Interns.info(NUM_DEAD_REGION_SERVERS_NAME, NUMBER_OF_DEAD_REGION_SERVERS_DESC), - masterWrapper.getDeadRegionServers()) + masterWrapper.getNumDeadRegionServers()) .tag(Interns.info(ZOOKEEPER_QUORUM_NAME, ZOOKEEPER_QUORUM_DESC), masterWrapper.getZookeeperQuorum()) .tag(Interns.info(SERVER_NAME_NAME, SERVER_NAME_DESC), masterWrapper.getServerName()) Modified: hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapperImpl.java URL: http://svn.apache.org/viewvc/hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapperImpl.java?rev=1571888&r1=1571887&r2=1571888&view=diff ============================================================================== --- hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapperImpl.java (original) +++ hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapperImpl.java Wed Feb 26 01:02:05 2014 @@ -17,14 +17,15 @@ */ package org.apache.hadoop.hbase.master; +import org.apache.commons.lang.StringUtils; +import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.hbase.ServerName; -import org.apache.hadoop.hbase.master.HMaster; -import org.apache.hadoop.hbase.master.MetricsMasterWrapper; import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher; /** * Impl for exposing HMaster Information through JMX */ +@InterfaceAudience.Private public class MetricsMasterWrapperImpl implements MetricsMasterWrapper { private final HMaster master; @@ -68,7 +69,16 @@ public class MetricsMasterWrapperImpl im } @Override - public int getRegionServers() { + public String getRegionServers() { + ServerManager serverManager = this.master.getServerManager(); + if (serverManager == null) { + return ""; + } + return StringUtils.join(serverManager.getOnlineServers().keySet(), ";"); + } + + @Override + public int getNumRegionServers() { ServerManager serverManager = this.master.getServerManager(); if (serverManager == null) { return 0; @@ -77,7 +87,17 @@ public class MetricsMasterWrapperImpl im } @Override - public int getDeadRegionServers() { + public String getDeadRegionServers() { + ServerManager serverManager = this.master.getServerManager(); + if (serverManager == null) { + return ""; + } + return StringUtils.join(serverManager.getDeadServers().copyServerNames(), ";"); + } + + + @Override + public int getNumDeadRegionServers() { ServerManager serverManager = this.master.getServerManager(); if (serverManager == null) { return 0; Modified: hbase/branches/0.96/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMasterMetricsWrapper.java URL: http://svn.apache.org/viewvc/hbase/branches/0.96/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMasterMetricsWrapper.java?rev=1571888&r1=1571887&r2=1571888&view=diff ============================================================================== --- hbase/branches/0.96/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMasterMetricsWrapper.java (original) +++ hbase/branches/0.96/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestMasterMetricsWrapper.java Wed Feb 26 01:02:05 2014 @@ -56,8 +56,8 @@ public class TestMasterMetricsWrapper { assertEquals(master.getMasterActiveTime(), info.getActiveTime()); assertEquals(master.getMasterStartTime(), info.getStartTime()); assertEquals(master.getCoprocessors().length, info.getCoprocessors().length); - assertEquals(master.getServerManager().getOnlineServersList().size(), info.getRegionServers()); - assertTrue(info.getRegionServers() == 4); + assertEquals(master.getServerManager().getOnlineServersList().size(), info.getNumRegionServers()); + assertTrue(info.getNumRegionServers() == 4); String zkServers = info.getZookeeperQuorum(); assertEquals(zkServers.split(",").length, TEST_UTIL.getZkCluster().getZooKeeperServerNum()); @@ -72,7 +72,7 @@ public class TestMasterMetricsWrapper { index) { Threads.sleep(10); } - assertTrue(info.getRegionServers() == 3); - assertTrue(info.getDeadRegionServers() == 1); + assertTrue(info.getNumRegionServers() == 3); + assertTrue(info.getNumDeadRegionServers() == 1); } } \ No newline at end of file