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

HBASE-7299 TestMultiParallel fails intermittently in trunk builds, addendum 4 (Chunhui) 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1435301 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Zhihong Yu 2013-01-18 18:49:42 +00:00
parent 0c9a81436e
commit c19520a956
1 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java
View File

@ -18,6 +18,11 @@
*/ */
package org.apache.hadoop.hbase.client; package org.apache.hadoop.hbase.client;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
import java.io.IOException; import java.io.IOException;
import java.lang.reflect.Field; import java.lang.reflect.Field;
import java.util.ArrayList; import java.util.ArrayList;
@ -27,9 +32,13 @@ import java.util.concurrent.ThreadPoolExecutor;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.apache.commons.logging.impl.Log4JLogger; import org.apache.commons.logging.impl.Log4JLogger;
import org.apache.hadoop.hbase.*; import org.apache.hadoop.hbase.HBaseTestingUtility;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.MediumTests;
import org.apache.hadoop.hbase.Waiter.Predicate;
import org.apache.hadoop.hbase.ipc.HBaseClient; import org.apache.hadoop.hbase.ipc.HBaseClient;
import org.apache.hadoop.hbase.ipc.HBaseServer; import org.apache.hadoop.hbase.ipc.HBaseServer;
import org.apache.hadoop.hbase.master.RegionStates;
import org.apache.hadoop.hbase.protobuf.ProtobufUtil; import org.apache.hadoop.hbase.protobuf.ProtobufUtil;
import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.JVMClusterUtil; import org.apache.hadoop.hbase.util.JVMClusterUtil;
@ -41,8 +50,6 @@ import org.junit.BeforeClass;
import org.junit.Test; import org.junit.Test;
import org.junit.experimental.categories.Category; import org.junit.experimental.categories.Category;
import static org.junit.Assert.*;
@Category(MediumTests.class) @Category(MediumTests.class)
public class TestMultiParallel { public class TestMultiParallel {
private static final Log LOG = LogFactory.getLog(TestMultiParallel.class); private static final Log LOG = LogFactory.getLog(TestMultiParallel.class);
@ -73,11 +80,20 @@ public class TestMultiParallel {
UTIL.shutdownMiniCluster(); UTIL.shutdownMiniCluster();
} }
@Before public void before() throws IOException { @Before public void before() throws Exception {
LOG.info("before"); LOG.info("before");
if (UTIL.ensureSomeRegionServersAvailable(slaves)) { if (UTIL.ensureSomeRegionServersAvailable(slaves)) {
// Distribute regions // Distribute regions
UTIL.getMiniHBaseCluster().getMaster().balance(); UTIL.getMiniHBaseCluster().getMaster().balance();
// Wait until completing balance
final RegionStates regionStates = UTIL.getMiniHBaseCluster().getMaster()
.getAssignmentManager().getRegionStates();
UTIL.waitFor(15 * 1000, new Predicate<Exception>() {
@Override
public boolean evaluate() throws Exception {
return !regionStates.isRegionsInTransition();
}
});
} }
LOG.info("before done"); LOG.info("before done");
} }