diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestCompactedHFilesDischarger.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestCompactedHFilesDischarger.java index 773a786..1cff934 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestCompactedHFilesDischarger.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestCompactedHFilesDischarger.java @@ -383,8 +383,8 @@ public class TestCompactedHFilesDischarger { latch.await(); } catch (InterruptedException e) { } - while (!next) { - resScanner.next(results); + while (next) { + next = resScanner.next(results); } } finally { scanCompletedCounter.incrementAndGet();