You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jx...@apache.org on 2013/10/25 19:12:26 UTC
svn commit: r1535786 -
/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRSKilledWhenInitializing.java
Author: jxiang
Date: Fri Oct 25 17:12:26 2013
New Revision: 1535786
URL: http://svn.apache.org/r1535786
Log:
Fix CRLF in TestRSKilledWhenInitializing.java
Modified:
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRSKilledWhenInitializing.java
Modified: hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRSKilledWhenInitializing.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRSKilledWhenInitializing.java?rev=1535786&r1=1535785&r2=1535786&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRSKilledWhenInitializing.java (original)
+++ hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRSKilledWhenInitializing.java Fri Oct 25 17:12:26 2013
@@ -1,130 +1,130 @@
-/**
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.hadoop.hbase.regionserver;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
-
-import java.io.IOException;
-import java.util.List;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.hbase.HBaseConfiguration;
-import org.apache.hadoop.hbase.HBaseTestingUtility;
-import org.apache.hadoop.hbase.HConstants;
-import org.apache.hadoop.hbase.LargeTests;
-import org.apache.hadoop.hbase.LocalHBaseCluster;
-import org.apache.hadoop.hbase.MiniHBaseCluster;
-import org.apache.hadoop.hbase.ServerName;
-import org.apache.hadoop.hbase.master.HMaster;
-import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.NameStringPair;
-import org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse;
-import org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread;
-import org.apache.hadoop.hbase.util.Threads;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
-/**
- * Tests region server termination during startup.
- */
-@Category(LargeTests.class)
-public class TestRSKilledWhenInitializing {
- private static final Log LOG = LogFactory.getLog(TestRSKilledWhenInitializing.class);
-
- private static boolean masterActive = false;
-
- /**
- * Test verifies whether a region server is removing from online servers list in master if it went
- * down after registering with master.
- * @throws Exception
- */
- @Test(timeout = 180000)
- public void testRSTermnationAfterRegisteringToMasterBeforeCreatingEphemeralNod() throws Exception {
-
- final int NUM_MASTERS = 1;
- final int NUM_RS = 1;
- // Create config to use for this cluster
- Configuration conf = HBaseConfiguration.create();
-
- // Start the cluster
- final HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(conf);
- TEST_UTIL.startMiniDFSCluster(3);
- TEST_UTIL.startMiniZKCluster();
- TEST_UTIL.createRootDir();
- final LocalHBaseCluster cluster =
- new LocalHBaseCluster(conf, NUM_MASTERS, NUM_RS, HMaster.class, MockedRegionServer.class);
- final MasterThread master = cluster.getMasters().get(0);
- master.start();
- try {
- long startTime = System.currentTimeMillis();
- while (!master.getMaster().isActiveMaster()) {
- try {
- Thread.sleep(100);
- } catch (InterruptedException ignored) {
- }
- if (System.currentTimeMillis() > startTime + 30000) {
- throw new RuntimeException("Master not active after 30 seconds");
- }
- }
- masterActive = true;
- cluster.getRegionServers().get(0).start();
- Thread.sleep(10000);
- List<ServerName> onlineServersList =
- master.getMaster().getServerManager().getOnlineServersList();
- while (!onlineServersList.isEmpty()) {
- Thread.sleep(100);
- onlineServersList = master.getMaster().getServerManager().getOnlineServersList();
- }
- assertTrue(onlineServersList.isEmpty());
- master.getMaster().stop("stopping master");
- master.join();
- } finally {
- masterActive = false;
- TEST_UTIL.shutdownMiniZKCluster();
- TEST_UTIL.shutdownMiniDFSCluster();
- TEST_UTIL.cleanupTestDir();
- }
- }
-
- public static class MockedRegionServer extends MiniHBaseCluster.MiniHBaseClusterRegionServer {
-
- public MockedRegionServer(Configuration conf) throws IOException, InterruptedException {
- super(conf);
- }
-
- @Override
- protected void handleReportForDutyResponse(RegionServerStartupResponse c) throws IOException {
- for (NameStringPair e : c.getMapEntriesList()) {
- String key = e.getName();
- // The hostname the master sees us as.
- if (key.equals(HConstants.KEY_FOR_HOSTNAME_SEEN_BY_MASTER)) {
- String hostnameFromMasterPOV = e.getValue();
- assertEquals(super.getRpcServer().getListenerAddress().getHostName(),
- hostnameFromMasterPOV);
- }
- }
- while (!masterActive) {
- Threads.sleep(100);
- }
- super.kill();
- }
- }
-}
+/**
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.hbase.regionserver;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+import java.io.IOException;
+import java.util.List;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.HBaseConfiguration;
+import org.apache.hadoop.hbase.HBaseTestingUtility;
+import org.apache.hadoop.hbase.HConstants;
+import org.apache.hadoop.hbase.LargeTests;
+import org.apache.hadoop.hbase.LocalHBaseCluster;
+import org.apache.hadoop.hbase.MiniHBaseCluster;
+import org.apache.hadoop.hbase.ServerName;
+import org.apache.hadoop.hbase.master.HMaster;
+import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.NameStringPair;
+import org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse;
+import org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread;
+import org.apache.hadoop.hbase.util.Threads;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+/**
+ * Tests region server termination during startup.
+ */
+@Category(LargeTests.class)
+public class TestRSKilledWhenInitializing {
+ private static final Log LOG = LogFactory.getLog(TestRSKilledWhenInitializing.class);
+
+ private static boolean masterActive = false;
+
+ /**
+ * Test verifies whether a region server is removing from online servers list in master if it went
+ * down after registering with master.
+ * @throws Exception
+ */
+ @Test(timeout = 180000)
+ public void testRSTermnationAfterRegisteringToMasterBeforeCreatingEphemeralNod() throws Exception {
+
+ final int NUM_MASTERS = 1;
+ final int NUM_RS = 1;
+ // Create config to use for this cluster
+ Configuration conf = HBaseConfiguration.create();
+
+ // Start the cluster
+ final HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(conf);
+ TEST_UTIL.startMiniDFSCluster(3);
+ TEST_UTIL.startMiniZKCluster();
+ TEST_UTIL.createRootDir();
+ final LocalHBaseCluster cluster =
+ new LocalHBaseCluster(conf, NUM_MASTERS, NUM_RS, HMaster.class, MockedRegionServer.class);
+ final MasterThread master = cluster.getMasters().get(0);
+ master.start();
+ try {
+ long startTime = System.currentTimeMillis();
+ while (!master.getMaster().isActiveMaster()) {
+ try {
+ Thread.sleep(100);
+ } catch (InterruptedException ignored) {
+ }
+ if (System.currentTimeMillis() > startTime + 30000) {
+ throw new RuntimeException("Master not active after 30 seconds");
+ }
+ }
+ masterActive = true;
+ cluster.getRegionServers().get(0).start();
+ Thread.sleep(10000);
+ List<ServerName> onlineServersList =
+ master.getMaster().getServerManager().getOnlineServersList();
+ while (!onlineServersList.isEmpty()) {
+ Thread.sleep(100);
+ onlineServersList = master.getMaster().getServerManager().getOnlineServersList();
+ }
+ assertTrue(onlineServersList.isEmpty());
+ master.getMaster().stop("stopping master");
+ master.join();
+ } finally {
+ masterActive = false;
+ TEST_UTIL.shutdownMiniZKCluster();
+ TEST_UTIL.shutdownMiniDFSCluster();
+ TEST_UTIL.cleanupTestDir();
+ }
+ }
+
+ public static class MockedRegionServer extends MiniHBaseCluster.MiniHBaseClusterRegionServer {
+
+ public MockedRegionServer(Configuration conf) throws IOException, InterruptedException {
+ super(conf);
+ }
+
+ @Override
+ protected void handleReportForDutyResponse(RegionServerStartupResponse c) throws IOException {
+ for (NameStringPair e : c.getMapEntriesList()) {
+ String key = e.getName();
+ // The hostname the master sees us as.
+ if (key.equals(HConstants.KEY_FOR_HOSTNAME_SEEN_BY_MASTER)) {
+ String hostnameFromMasterPOV = e.getValue();
+ assertEquals(super.getRpcServer().getListenerAddress().getHostName(),
+ hostnameFromMasterPOV);
+ }
+ }
+ while (!masterActive) {
+ Threads.sleep(100);
+ }
+ super.kill();
+ }
+ }
+}