Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-19840 Flakey TestMetaWithReplicas 

Adding debuging
This commit is contained in:
Michael Stack 2018-01-22 12:24:52 -08:00
parent 0fa24dddb9
commit 1e5fc1ed63
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestMetaWithReplicas.java
View File

@ -30,6 +30,8 @@ import java.util.Collection;
import java.util.EnumSet; import java.util.EnumSet;
import java.util.List; import java.util.List;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.atomic.AtomicBoolean;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Abortable; import org.apache.hadoop.hbase.Abortable;
import org.apache.hadoop.hbase.CategoryBasedTimeout; import org.apache.hadoop.hbase.CategoryBasedTimeout;
@ -93,14 +95,14 @@ public class TestMetaWithReplicas {
// disable the balancer // disable the balancer
LoadBalancerTracker l = new LoadBalancerTracker(TEST_UTIL.getZooKeeperWatcher(), LoadBalancerTracker l = new LoadBalancerTracker(TEST_UTIL.getZooKeeperWatcher(),
new Abortable() { new Abortable() {
boolean aborted = false; AtomicBoolean aborted = new AtomicBoolean(false);
@Override @Override
public boolean isAborted() { public boolean isAborted() {
return aborted; return aborted.get();
} }
@Override @Override
public void abort(String why, Throwable e) { public void abort(String why, Throwable e) {
aborted = true; aborted.set(true);
} }
}); });
l.setBalancerOn(false); l.setBalancerOn(false);
@ -174,6 +176,7 @@ public class TestMetaWithReplicas {
conf.get("zookeeper.znode.metaserver", "meta-region-server")); conf.get("zookeeper.znode.metaserver", "meta-region-server"));
byte[] data = ZKUtil.getData(zkw, primaryMetaZnode); byte[] data = ZKUtil.getData(zkw, primaryMetaZnode);
ServerName primary = ProtobufUtil.toServerName(data); ServerName primary = ProtobufUtil.toServerName(data);
LOG.info("Primary=" + primary.toString());
TableName TABLE = TableName.valueOf("testShutdownHandling"); TableName TABLE = TableName.valueOf("testShutdownHandling");
byte[][] FAMILIES = new byte[][] { Bytes.toBytes("foo") }; byte[][] FAMILIES = new byte[][] { Bytes.toBytes("foo") };
@ -208,14 +211,17 @@ public class TestMetaWithReplicas {
master = util.getHBaseClusterInterface().getClusterMetrics().getMasterName(); master = util.getHBaseClusterInterface().getClusterMetrics().getMasterName();
// kill the master so that regionserver recovery is not triggered at all // kill the master so that regionserver recovery is not triggered at all
// for the meta server // for the meta server
LOG.info("Stopping master=" + master.toString());
util.getHBaseClusterInterface().stopMaster(master); util.getHBaseClusterInterface().stopMaster(master);
util.getHBaseClusterInterface().waitForMasterToStop(master, 60000); util.getHBaseClusterInterface().waitForMasterToStop(master, 60000);
LOG.info("Master stopped!");
if (!master.equals(primary)) { if (!master.equals(primary)) {
util.getHBaseClusterInterface().killRegionServer(primary); util.getHBaseClusterInterface().killRegionServer(primary);
util.getHBaseClusterInterface().waitForRegionServerToStop(primary, 60000); util.getHBaseClusterInterface().waitForRegionServerToStop(primary, 60000);
} }
((ClusterConnection)c).clearRegionCache(); ((ClusterConnection)c).clearRegionCache();
} }
LOG.info("Running GETs");
Get get = null; Get get = null;
Result r = null; Result r = null;
byte[] row = "test".getBytes(); byte[] row = "test".getBytes();
@ -231,12 +237,15 @@ public class TestMetaWithReplicas {
assertTrue(Arrays.equals(r.getRow(), row)); assertTrue(Arrays.equals(r.getRow(), row));
// now start back the killed servers and disable use of replicas. That would mean // now start back the killed servers and disable use of replicas. That would mean
// calls go to the primary // calls go to the primary
LOG.info("Starting Master");
util.getHBaseClusterInterface().startMaster(master.getHostname(), 0); util.getHBaseClusterInterface().startMaster(master.getHostname(), 0);
util.getHBaseClusterInterface().startRegionServer(primary.getHostname(), 0); util.getHBaseClusterInterface().startRegionServer(primary.getHostname(), 0);
util.getHBaseClusterInterface().waitForActiveAndReadyMaster(); util.getHBaseClusterInterface().waitForActiveAndReadyMaster();
LOG.info("Master active!");
((ClusterConnection)c).clearRegionCache(); ((ClusterConnection)c).clearRegionCache();
} }
conf.setBoolean(HConstants.USE_META_REPLICAS, false); conf.setBoolean(HConstants.USE_META_REPLICAS, false);
LOG.info("Running GETs no replicas");
try (Table htable = c.getTable(TABLE);) { try (Table htable = c.getTable(TABLE);) {
r = htable.get(get); r = htable.get(get);
assertTrue(Arrays.equals(r.getRow(), row)); assertTrue(Arrays.equals(r.getRow(), row));