You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ra...@apache.org on 2017/12/11 17:25:13 UTC
hbase git commit: HBASE-19485 Minor improvement to
TestCompactedHFilesDischarger (Ram)
Repository: hbase
Updated Branches:
refs/heads/master 08d6b5575 -> eb67ee0d0
HBASE-19485 Minor improvement to TestCompactedHFilesDischarger (Ram)
Signed off by : Ted Yu <yu...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/eb67ee0d
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/eb67ee0d
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/eb67ee0d
Branch: refs/heads/master
Commit: eb67ee0d0f4124b0efef20f7d674b5b746a8cc0c
Parents: 08d6b55
Author: Vasudevan <ra...@intel.com>
Authored: Mon Dec 11 22:53:46 2017 +0530
Committer: Vasudevan <ra...@intel.com>
Committed: Mon Dec 11 22:53:46 2017 +0530
----------------------------------------------------------------------
.../regionserver/compactions/TestCompactedHFilesDischarger.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/eb67ee0d/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestCompactedHFilesDischarger.java
----------------------------------------------------------------------
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();