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

HBASE-8960: TestDistributedLogSplitting.testLogReplayForDisablingTable fails sometimes 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1504321 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
jeffreyz 2013-07-17 23:29:22 +00:00
parent a7d4085586
commit c9ca3ceffa
1 changed files with 21 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java
View File

@ -700,18 +700,23 @@ public class TestDistributedLogSplitting {
startCluster(NUM_RS, curConf); startCluster(NUM_RS, curConf);
final int NUM_REGIONS_TO_CREATE = 40; final int NUM_REGIONS_TO_CREATE = 40;
final int NUM_LOG_LINES = 1000; final int NUM_LOG_LINES = 1000;
// turn off load balancing to prevent regions from moving around otherwise
// they will consume recovered.edits
master.balanceSwitch(false);
List<RegionServerThread> rsts = cluster.getLiveRegionServerThreads(); List<RegionServerThread> rsts = cluster.getLiveRegionServerThreads();
final ZooKeeperWatcher zkw = new ZooKeeperWatcher(conf, "table-creation", null); final ZooKeeperWatcher zkw = new ZooKeeperWatcher(conf, "table-creation", null);
HTable disablingHT = installTable(zkw, "disableTable", "family", NUM_REGIONS_TO_CREATE); HTable disablingHT = installTable(zkw, "disableTable", "family", NUM_REGIONS_TO_CREATE);
HTable ht = installTable(zkw, "table", "family", NUM_REGIONS_TO_CREATE, NUM_REGIONS_TO_CREATE); HTable ht = installTable(zkw, "table", "family", NUM_REGIONS_TO_CREATE, NUM_REGIONS_TO_CREATE);
// turn off load balancing to prevent regions from moving around otherwise
// they will consume recovered.edits
master.balanceSwitch(false);
List<HRegionInfo> regions = null; List<HRegionInfo> regions = null;
HRegionServer hrs = null; HRegionServer hrs = null;
boolean hasRegionsForBothTables = false;
String tableName = null;
for (int i = 0; i < NUM_RS; i++) { for (int i = 0; i < NUM_RS; i++) {
tableName = null;
hasRegionsForBothTables = false;
boolean isCarryingMeta = false; boolean isCarryingMeta = false;
hrs = rsts.get(i).getRegionServer(); hrs = rsts.get(i).getRegionServer();
regions = ProtobufUtil.getOnlineRegions(hrs); regions = ProtobufUtil.getOnlineRegions(hrs);
@ -720,12 +725,24 @@ public class TestDistributedLogSplitting {
isCarryingMeta = true; isCarryingMeta = true;
break; break;
} }
if (tableName != null && !tableName.equalsIgnoreCase(region.getTableNameAsString())) {
// make sure that we find a RS has online regions for both "table" and "disableTable"
hasRegionsForBothTables = true;
break;
} else if (tableName == null) {
tableName = region.getTableNameAsString();
}
} }
if (isCarryingMeta) { if (isCarryingMeta) {
continue; continue;
} }
if (hasRegionsForBothTables) {
break; break;
} }
}
// make sure we found a good RS
Assert.assertTrue(hasRegionsForBothTables);
LOG.info("#regions = " + regions.size()); LOG.info("#regions = " + regions.size());
Iterator<HRegionInfo> it = regions.iterator(); Iterator<HRegionInfo> it = regions.iterator();