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

HBASE-8922 TestAdmin.testForceSplitMultiFamily fails in hadoopqa; DEBUG; REAPPLY 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1502015 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2013-07-10 21:36:28 +00:00
parent 2d16811fce
commit 920c2a029a
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAdmin.java
View File

@ -927,7 +927,12 @@ public class TestAdmin {
void splitTest(byte[] splitPoint, byte[][] familyNames, int[] rowCounts, void splitTest(byte[] splitPoint, byte[][] familyNames, int[] rowCounts,
int numVersions, int blockSize) throws Exception { int numVersions, int blockSize) throws Exception {
byte [] tableName = Bytes.toBytes("testForceSplit"); StringBuilder sb = new StringBuilder();
// Add tail to String so can see better in logs where a test is running.
for (int i = 0; i < rowCounts.length; i++) {
sb.append("_").append(Integer.toString(rowCounts[i]));
}
byte [] tableName = Bytes.toBytes("testForceSplit" + sb.toString());
assertFalse(admin.tableExists(tableName)); assertFalse(admin.tableExists(tableName));
final HTable table = TEST_UTIL.createTable(tableName, familyNames, final HTable table = TEST_UTIL.createTable(tableName, familyNames,
numVersions, blockSize); numVersions, blockSize);
@ -954,7 +959,7 @@ public class TestAdmin {
// get the initial layout (should just be one region) // get the initial layout (should just be one region)
Map<HRegionInfo, ServerName> m = table.getRegionLocations(); Map<HRegionInfo, ServerName> m = table.getRegionLocations();
System.out.println("Initial regions (" + m.size() + "): " + m); LOG.info("Initial regions (" + m.size() + "): " + m);
assertTrue(m.size() == 1); assertTrue(m.size() == 1);
// Verify row count // Verify row count
@ -994,7 +999,10 @@ public class TestAdmin {
} }
if (regions == null) continue; if (regions == null) continue;
count.set(regions.size()); count.set(regions.size());
if (count.get() >= 2) break; if (count.get() >= 2) {
LOG.info("Found: " + regions);
break;
}
LOG.debug("Cycle waiting on split"); LOG.debug("Cycle waiting on split");
} }
LOG.debug("CheckForSplit thread exited, current region count: " + count.get()); LOG.debug("CheckForSplit thread exited, current region count: " + count.get());
@ -1038,7 +1046,8 @@ public class TestAdmin {
// check if splitKey is based on the largest column family // check if splitKey is based on the largest column family
// in terms of it store size // in terms of it store size
int deltaForLargestFamily = Math.abs(rowCount/2 - splitKey); int deltaForLargestFamily = Math.abs(rowCount/2 - splitKey);
LOG.debug("SplitKey=" + splitKey + "&deltaForLargestFamily=" + deltaForLargestFamily); LOG.debug("SplitKey=" + splitKey + "&deltaForLargestFamily=" + deltaForLargestFamily +
", r=" + r[0]);
for (int index = 0; index < familyNames.length; index++) { for (int index = 0; index < familyNames.length; index++) {
int delta = Math.abs(rowCounts[index]/2 - splitKey); int delta = Math.abs(rowCounts[index]/2 - splitKey);
if (delta < deltaForLargestFamily) { if (delta < deltaForLargestFamily) {