Repository: hbase Updated Branches: refs/heads/branch-1.0 82dc2e62b -> a5cfd4953
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/a5cfd495 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/a5cfd495 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/a5cfd495 Branch: refs/heads/branch-1.0 Commit: a5cfd4953d71e244742e9a90bbe2171b56262d7c Parents: 82dc2e6 Author: stack <[email protected]> Authored: Mon Jan 5 21:17:19 2015 -0800 Committer: stack <[email protected]> Committed: Mon Jan 5 21:17:19 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/a5cfd495/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();
