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

HBASE-5112 TestReplication#queueFailover flaky due to potentially 

uninitialized Scan (Jimmy Xiang)


git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1226039 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Zhihong Yu 2011-12-31 05:03:49 +00:00
parent ddd384369f
commit 10e6defda5
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGES.txt
View File

@ -482,6 +482,8 @@ Release 0.92.0 - Unreleased
HBASE-4868 TestOfflineMetaRebuildBase#testMetaRebuild occasionally fails HBASE-4868 TestOfflineMetaRebuildBase#testMetaRebuild occasionally fails
(Gao Jinchao) (Gao Jinchao)
HBASE-4874 Run tests with non-secure random, some tests hang otherwise (Lars H) HBASE-4874 Run tests with non-secure random, some tests hang otherwise (Lars H)
HBASE-5112 TestReplication#queueFailover flaky due to potentially
uninitialized Scan (Jimmy Xiang)
IMPROVEMENTS IMPROVEMENTS
HBASE-3290 Max Compaction Size (Nicolas Spiegelberg via Stack) HBASE-3290 Max Compaction Size (Nicolas Spiegelberg via Stack)

4
src/test/java/org/apache/hadoop/hbase/replication/TestReplication.java
View File

@ -649,14 +649,13 @@ public class TestReplication {
initialCount = res.length; initialCount = res.length;
} }
Scan scan2 = new Scan();
int lastCount = 0; int lastCount = 0;
for (int i = 0; i < NB_RETRIES; i++) { for (int i = 0; i < NB_RETRIES; i++) {
if (i==NB_RETRIES-1) { if (i==NB_RETRIES-1) {
fail("Waited too much time for queueFailover replication"); fail("Waited too much time for queueFailover replication");
} }
Scan scan2 = new Scan();
ResultScanner scanner2 = htable2.getScanner(scan2); ResultScanner scanner2 = htable2.getScanner(scan2);
Result[] res2 = scanner2.next(initialCount * 2); Result[] res2 = scanner2.next(initialCount * 2);
scanner2.close(); scanner2.close();
@ -686,6 +685,7 @@ public class TestReplication {
} }
} }
}; };
killer.setDaemon(true);
killer.start(); killer.start();
return killer; return killer;
} }