diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestServerName.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestServerName.java index a6e1401038f..2fdf542d814 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestServerName.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestServerName.java @@ -22,6 +22,8 @@ import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertNotSame; import static org.junit.Assert.assertTrue; +import java.util.HashSet; +import java.util.Set; import java.util.regex.Pattern; import org.apache.hadoop.hbase.testclassification.MiscTests; import org.apache.hadoop.hbase.testclassification.SmallTests; @@ -38,6 +40,17 @@ public class TestServerName { public static final HBaseClassTestRule CLASS_RULE = HBaseClassTestRule.forClass(TestServerName.class); + @Test + public void testHash() { + ServerName sn1 = ServerName.parseServerName("asf903.gq1.ygridcore.net,52690,1517835491385"); + ServerName sn2 = ServerName.parseServerName("asf903.gq1.ygridcore.net,42231,1517835491329"); + Set sns = new HashSet(); + sns.add(sn2); + sns.add(sn1); + sns.add(sn1); + assertEquals(2, sns.size()); + } + @Test public void testGetHostNameMinusDomain() { assertEquals("2607:f0d0:1002:51::4", diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestMetaWithReplicas.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestMetaWithReplicas.java index ecd458d07d6..2834d178fbd 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestMetaWithReplicas.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestMetaWithReplicas.java @@ -98,14 +98,19 @@ public class TestMetaWithReplicas { TEST_UTIL.startMiniCluster(REGIONSERVERS_COUNT); AssignmentManager am = TEST_UTIL.getMiniHBaseCluster().getMaster().getAssignmentManager(); Set sns = new HashSet(); - for (int replicaId = 0; replicaId < 3; replicaId ++) { + ServerName hbaseMetaServerName = + TEST_UTIL.getMiniHBaseCluster().getMaster().getMetaTableLocator(). + getMetaRegionLocation(TEST_UTIL.getZooKeeperWatcher()); + LOG.info("HBASE:META DEPLOY: on " + hbaseMetaServerName); + sns.add(hbaseMetaServerName); + for (int replicaId = 1; replicaId < 3; replicaId ++) { RegionInfo h = RegionReplicaUtil.getRegionInfoForReplica(RegionInfoBuilder.FIRST_META_REGIONINFO, replicaId); try { am.waitForAssignment(h); ServerName sn = am.getRegionStates().getRegionServerOfRegion(h); - LOG.info(h.getRegionNameAsString() + " on " + sn); + LOG.info("HBASE:META DEPLOY: " + h.getRegionNameAsString() + " on " + sn); sns.add(sn); } catch (NoSuchProcedureException e) { LOG.info("Presume the procedure has been cleaned up so just proceed: " + e.toString()); @@ -116,7 +121,7 @@ public class TestMetaWithReplicas { if (sns.size() == 1) { int count = TEST_UTIL.getMiniHBaseCluster().getLiveRegionServerThreads().size(); assertTrue("count=" + count, count == REGIONSERVERS_COUNT); - LOG.warn("All hbase:meta replicas are on the one server; moving hbase:meta"); + LOG.warn("All hbase:meta replicas are on the one server; moving hbase:meta: " + sns); int metaServerIndex = TEST_UTIL.getHBaseCluster().getServerWithMeta(); int newServerIndex = metaServerIndex; while (newServerIndex == metaServerIndex) {