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

Added extra logging and a retry before throwing assertion to TestSplitTransactionOnCluster, a commonly failing test 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1088068 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2011-04-02 18:09:19 +00:00
parent eb791700ee
commit 1e6b64f3af
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransactionOnCluster.java
View File

@ -97,8 +97,7 @@ public class TestSplitTransactionOnCluster {
*/ */
@Test (timeout = 600000) public void testPendingCloseAndSplit() @Test (timeout = 600000) public void testPendingCloseAndSplit()
throws IOException, InterruptedException, NodeExistsException, KeeperException { throws IOException, InterruptedException, NodeExistsException, KeeperException {
final byte [] tableName = final byte [] tableName = Bytes.toBytes("pendingCloseAndSplit");
Bytes.toBytes("pendingClose");
// Create table then get the single region for our new table. // Create table then get the single region for our new table.
HTable t = TESTING_UTIL.createTable(tableName, HConstants.CATALOG_FAMILY); HTable t = TESTING_UTIL.createTable(tableName, HConstants.CATALOG_FAMILY);
@ -126,6 +125,7 @@ public class TestSplitTransactionOnCluster {
MiniHBaseCluster.MiniHBaseClusterRegionServer.TEST_SKIP_CLOSE = true; MiniHBaseCluster.MiniHBaseClusterRegionServer.TEST_SKIP_CLOSE = true;
this.cluster.getMaster().unassign(hri.getRegionName(), false); this.cluster.getMaster().unassign(hri.getRegionName(), false);
// Now try splitting and it should work. // Now try splitting and it should work.
LOG.info("Running split on server " + server.toString());
split(hri, server, regionCount); split(hri, server, regionCount);
// Get daughters // Get daughters
List<HRegion> daughters = this.cluster.getRegions(tableName); List<HRegion> daughters = this.cluster.getRegions(tableName);
@ -133,8 +133,14 @@ public class TestSplitTransactionOnCluster {
// Assert the ephemeral node is gone in zk. // Assert the ephemeral node is gone in zk.
String path = ZKAssign.getNodeName(t.getConnection().getZooKeeperWatcher(), String path = ZKAssign.getNodeName(t.getConnection().getZooKeeperWatcher(),
hri.getEncodedName()); hri.getEncodedName());
Stat stats = t.getConnection().getZooKeeperWatcher().getZooKeeper().exists(path, false); Stat stat = null;
assertTrue(stats == null); for (int i = 0; i < 10; i++) {
stat = t.getConnection().getZooKeeperWatcher().getZooKeeper().exists(path, false);
LOG.info("Stat for znode path=" + path + ": " + stat);
if (stat == null) break;
org.apache.hadoop.hbase.util.Threads.sleep(100);
}
assertTrue(stat == null);
} finally { } finally {
// Set this flag back. // Set this flag back.
MiniHBaseCluster.MiniHBaseClusterRegionServer.TEST_SKIP_CLOSE = false; MiniHBaseCluster.MiniHBaseClusterRegionServer.TEST_SKIP_CLOSE = false;