Repository: hbase Updated Branches: refs/heads/branch-1 e491f337f -> 6fcc8d7c3
HBASE-12771 TestFailFast#testFastFail failing (Manukranth Kolloju) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/6fcc8d7c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/6fcc8d7c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/6fcc8d7c Branch: refs/heads/branch-1 Commit: 6fcc8d7c3e00545b795f8668040aa6db373ded8b Parents: e491f33 Author: stack <[email protected]> Authored: Mon Jan 5 21:17:19 2015 -0800 Committer: stack <[email protected]> Committed: Mon Jan 5 21:17:51 2015 -0800 ---------------------------------------------------------------------- .../org/apache/hadoop/hbase/client/TestFastFail.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/6fcc8d7c/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFastFail.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFastFail.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFastFail.java index 75334d3..bace0af 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFastFail.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFastFail.java @@ -42,6 +42,8 @@ import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.exceptions.PreemptiveFastFailException; +import org.apache.hadoop.hbase.regionserver.HRegion; +import org.apache.hadoop.hbase.regionserver.HRegionServer; import org.apache.hadoop.hbase.testclassification.MediumTests; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.test.LoadTestKVGenerator; @@ -219,8 +221,14 @@ public class TestFastFail { ClusterStatus status = TEST_UTIL.getHBaseCluster().getClusterStatus(); // Kill a regionserver - TEST_UTIL.getHBaseCluster().getRegionServer(0).getRpcServer().stop(); - TEST_UTIL.getHBaseCluster().getRegionServer(0).stop("Testing"); + for (int i = 0; i < SLAVES; i++) { + HRegionServer server = TEST_UTIL.getHBaseCluster().getRegionServer(i); + List<HRegion> regions = server.getOnlineRegions(TableName.META_TABLE_NAME); + if (regions.size() > 0) continue; // We don't want to kill META table because that adds extra + // latencies which can't be tested very easily. + server.getRpcServer().stop(); + server.stop("Testing"); + } // Let the threads continue going continueOtherHalf.countDown();
