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

HBASE-6714 TestMultiSlaveReplication#testMultiSlaveReplication may fail 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1388620 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2012-09-21 19:00:35 +00:00
parent 93d2fc5ce2
commit 1e3b48ec53
1 changed files with 27 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestMultiSlaveReplication.java
View File

@ -173,7 +173,10 @@ public class TestMultiSlaveReplication {
deleteAndWait(row2, htable1, htable2, htable3); deleteAndWait(row2, htable1, htable2, htable3);
// Even if the log was rolled in the middle of the replication // Even if the log was rolled in the middle of the replication
// "row" is still replication. // "row" is still replication.
checkRow(row, 1, htable2, htable3); checkRow(row, 1, htable2);
// Replication thread of cluster 2 may be sleeping, and since row2 is not there in it,
// we should wait before checking.
checkWithWait(row, 1, htable3);
// cleanup the rest // cleanup the rest
deleteAndWait(row, htable1, htable2, htable3); deleteAndWait(row, htable1, htable2, htable3);
@ -184,6 +187,28 @@ public class TestMultiSlaveReplication {
utility1.shutdownMiniCluster(); utility1.shutdownMiniCluster();
} }
private void checkWithWait(byte[] row, int count, HTable table) throws Exception {
Get get = new Get(row);
for (int i = 0; i < NB_RETRIES; i++) {
if (i == NB_RETRIES - 1) {
fail("Waited too much time while getting the row.");
}
boolean rowReplicated = false;
Result res = table.get(get);
if (res.size() >= 1) {
LOG.info("Row is replicated");
rowReplicated = true;
assertEquals(count, res.size());
break;
}
if (rowReplicated) {
break;
} else {
Thread.sleep(SLEEP_TIME);
}
}
}
private void checkRow(byte[] row, int count, HTable... tables) throws IOException { private void checkRow(byte[] row, int count, HTable... tables) throws IOException {
Get get = new Get(row); Get get = new Get(row);
for (HTable table : tables) { for (HTable table : tables) {