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

HBASE-4790 Occasional TestDistributedLogSplitting failure (Jinchao)

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1202312 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Zhihong Yu 2011-11-15 17:15:04 +00:00
parent ed36c7cbda
commit 48c16d1d66
2 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -438,6 +438,7 @@ Release 0.92.0 - Unreleased
HBASE-4651 ConcurrentModificationException might be thrown in HBASE-4651 ConcurrentModificationException might be thrown in
TestHCM.testConnectionUniqueness (Jinchao) TestHCM.testConnectionUniqueness (Jinchao)
HBASE-4518 TestServerCustomProtocol fails intermittently HBASE-4518 TestServerCustomProtocol fails intermittently
HBASE-4790 Occasional TestDistributedLogSplitting failure (Jinchao)
IMPROVEMENTS IMPROVEMENTS
HBASE-3290 Max Compaction Size (Nicolas Spiegelberg via Stack) HBASE-3290 Max Compaction Size (Nicolas Spiegelberg via Stack)

15
src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java
View File

@ -199,15 +199,22 @@ public class TestDistributedLogSplitting {
FileSystem fs = master.getMasterFileSystem().getFileSystem(); FileSystem fs = master.getMasterFileSystem().getFileSystem();
List<RegionServerThread> rsts = cluster.getLiveRegionServerThreads(); List<RegionServerThread> rsts = cluster.getLiveRegionServerThreads();
HRegionServer hrs = rsts.get(0).getRegionServer();
Path rootdir = FSUtils.getRootDir(conf); Path rootdir = FSUtils.getRootDir(conf);
final Path logDir = new Path(rootdir,
HLog.getHLogDirectoryName(hrs.getServerName().toString()));
installTable(new ZooKeeperWatcher(conf, "table-creation", null), installTable(new ZooKeeperWatcher(conf, "table-creation", null),
"table", "family", 40); "table", "family", 40);
byte[] table = Bytes.toBytes("table"); byte[] table = Bytes.toBytes("table");
List<HRegionInfo> regions = hrs.getOnlineRegions(); List<HRegionInfo> regions = null;
HRegionServer hrs = null;
for (int i = 0; i < NUM_RS; i++) {
hrs = rsts.get(i).getRegionServer();
regions = hrs.getOnlineRegions();
if (regions.size() != 0) break;
}
final Path logDir = new Path(rootdir, HLog.getHLogDirectoryName(hrs
.getServerName().toString()));
LOG.info("#regions = " + regions.size()); LOG.info("#regions = " + regions.size());
Iterator<HRegionInfo> it = regions.iterator(); Iterator<HRegionInfo> it = regions.iterator();
while (it.hasNext()) { while (it.hasNext()) {