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

HBASE-2624 TestMultiParallelPuts flaky on trunk 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@956270 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2010-06-19 19:00:41 +00:00
parent e7812957f3
commit a5408fc0e7
1 changed files with 12 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/test/java/org/apache/hadoop/hbase/TestMultiParallelPut.java
View File

@ -20,6 +20,8 @@
package org.apache.hadoop.hbase;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.HTable;
@ -31,6 +33,7 @@ import java.util.ArrayList;
import java.util.List;
public class TestMultiParallelPut extends MultiRegionTable {
final Log LOG = LogFactory.getLog(getClass());
private static final byte[] VALUE = Bytes.toBytes("value");
private static final byte[] QUALIFIER = Bytes.toBytes("qual");
private static final String FAMILY = "family";
@ -42,7 +45,6 @@ public class TestMultiParallelPut extends MultiRegionTable {
super(2, FAMILY);
desc = new HTableDescriptor(TEST_TABLE);
desc.addFamily(new HColumnDescriptor(FAMILY));
makeKeys();
}
@ -51,7 +53,6 @@ public class TestMultiParallelPut extends MultiRegionTable {
byte [] cp = new byte[k.length+1];
System.arraycopy(k, 0, cp, 0, k.length);
cp[k.length] = 1;
keys.add(cp);
}
}
@ -59,35 +60,33 @@ public class TestMultiParallelPut extends MultiRegionTable {
List<byte[]> keys = new ArrayList<byte[]>();
public void testParallelPut() throws Exception {
LOG.info("Starting testParallelPut");
doATest(false);
}
public void testParallelPutWithRSAbort() throws Exception {
LOG.info("Starting testParallelPutWithRSAbort");
doATest(true);
}
public void doATest(boolean doAbort) throws Exception {
HTable table = new HTable(TEST_TABLE);
table.setAutoFlush(false);
table.setWriteBufferSize(10 * 1024 * 1024);
for ( byte [] k : keys ) {
Put put = new Put(k);
put.add(BYTES_FAMILY, QUALIFIER, VALUE);
table.put(put);
}
table.flushCommits();
if (doAbort) {
LOG.info("Aborting...");
cluster.abortRegionServer(0);
// try putting more keys after the abort.
for ( byte [] k : keys ) {
Put put = new Put(k);
put.add(BYTES_FAMILY, QUALIFIER, VALUE);
table.put(put);
}
table.flushCommits();
@ -96,9 +95,7 @@ public class TestMultiParallelPut extends MultiRegionTable {
for (byte [] k : keys ) {
Get get = new Get(k);
get.addColumn(BYTES_FAMILY, QUALIFIER);
Result r = table.get(get);
assertTrue(r.containsColumn(BYTES_FAMILY, QUALIFIER));
assertEquals(0,
Bytes.compareTo(VALUE,
@ -107,16 +104,13 @@ public class TestMultiParallelPut extends MultiRegionTable {
HBaseAdmin admin = new HBaseAdmin(conf);
ClusterStatus cs = admin.getClusterStatus();
int expectedServerCount = 2;
if (doAbort)
expectedServerCount = 1;
if (doAbort) expectedServerCount = 1;
LOG.info("Clusterstatus servers count " + cs.getServers());
assertEquals(expectedServerCount, cs.getServers());
for ( HServerInfo info : cs.getServerInfo()) {
System.out.println(info);
assertTrue( info.getLoad().getNumberOfRegions() > 10);
LOG.info("Info from clusterstatus=" + info);
assertTrue(info.getLoad().getNumberOfRegions() > 8);
}
}
}
}