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

HBASE-15079 TestMultiParallel.validateLoadedData AssertionError: null

This commit is contained in:
stack 2016-01-07 15:35:59 -08:00
parent 5bde960b95
commit f3ee6df0f2
1 changed files with 35 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -683,13 +683,44 @@ public class TestMultiParallel {
private void validateLoadedData(Table table) throws IOException { private void validateLoadedData(Table table) throws IOException {
// get the data back and validate that it is correct // get the data back and validate that it is correct
LOG.info("Validating data on " + table); LOG.info("Validating data on " + table);
List<Get> gets = new ArrayList<Get>();
for (byte[] k : KEYS) { for (byte[] k : KEYS) {
Get get = new Get(k); Get get = new Get(k);
get.addColumn(BYTES_FAMILY, QUALIFIER); get.addColumn(BYTES_FAMILY, QUALIFIER);
Result r = table.get(get); gets.add(get);
Assert.assertTrue(r.containsColumn(BYTES_FAMILY, QUALIFIER)); }
Assert.assertEquals(0, Bytes.compareTo(VALUE, r int retryNum = 10;
.getValue(BYTES_FAMILY, QUALIFIER))); Result[] results = null;
do {
results = table.get(gets);
boolean finished = true;
for (Result result : results) {
if (result.isEmpty()) {
finished = false;
break;
}
}
if (finished) {
break;
}
try {
Thread.sleep(10);
} catch (InterruptedException e) {
}
retryNum--;
} while (retryNum > 0);
if (retryNum == 0) {
fail("Timeout for validate data");
} else {
if (results != null) {
for (Result r : results) {
Assert.assertTrue(r.containsColumn(BYTES_FAMILY, QUALIFIER));
Assert.assertEquals(0, Bytes.compareTo(VALUE, r
.getValue(BYTES_FAMILY, QUALIFIER)));
}
LOG.info("Validating data on " + table + " successfully!");
}
} }
} }