Index: src/test/java/org/apache/hadoop/hbase/replication/TestReplication.java =================================================================== --- src/test/java/org/apache/hadoop/hbase/replication/TestReplication.java (revision 1226028) +++ src/test/java/org/apache/hadoop/hbase/replication/TestReplication.java (working copy) @@ -656,14 +656,13 @@ initialCount = res.length; } - Scan scan2 = new Scan(); - int lastCount = 0; for (int i = 0; i < NB_RETRIES; i++) { if (i==NB_RETRIES-1) { fail("Waited too much time for queueFailover replication"); } + Scan scan2 = new Scan(); ResultScanner scanner2 = htable2.getScanner(scan2); Result[] res2 = scanner2.next(initialCount * 2); scanner2.close(); @@ -693,6 +692,7 @@ } } }; + killer.setDaemon(true); killer.start(); return killer; }