You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by la...@apache.org on 2014/01/10 01:51:43 UTC
svn commit: r1557003 -
/hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java
Author: larsh
Date: Fri Jan 10 00:51:43 2014
New Revision: 1557003
URL: http://svn.apache.org/r1557003
Log:
HBASE-10282 TestMultiParallel.testFlushCommitsNoAbort fails frequently in 0.94
Modified:
hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java
Modified: hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java?rev=1557003&r1=1557002&r2=1557003&view=diff
==============================================================================
--- hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java (original)
+++ hbase/branches/0.94/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java Fri Jan 10 00:51:43 2014
@@ -277,17 +277,16 @@ public class TestMultiParallel {
List<JVMClusterUtil.RegionServerThread> liveRSs =
UTIL.getMiniHBaseCluster().getLiveRegionServerThreads();
int count = 0;
+ int regionCount = 0;
for (JVMClusterUtil.RegionServerThread t: liveRSs) {
count++;
+ regionCount += t.getRegionServer().getOnlineRegions().size();
LOG.info("Count=" + count + ", Alive=" + t.getRegionServer());
}
LOG.info("Count=" + count);
Assert.assertEquals("Server count=" + count + ", abort=" + doAbort,
(doAbort ? (liveRScount - 1) : liveRScount), count);
- for (JVMClusterUtil.RegionServerThread t: liveRSs) {
- int regions = t.getRegionServer().getOnlineRegions().size();
- Assert.assertTrue("Count of regions=" + regions, regions > 10);
- }
+ Assert.assertTrue("Count of regions=" + regionCount, regionCount >= 25);
table.close();
LOG.info("done");
}