You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by en...@apache.org on 2014/06/28 02:31:19 UTC
[33/49] git commit: HBASE-10616. Addendum that fixes the case of
multiget_batchsize == 1
HBASE-10616. Addendum that fixes the case of multiget_batchsize == 1
git-svn-id: https://svn.apache.org/repos/asf/hbase/branches/hbase-10070@1577438 13f79535-47bb-0310-9956-ffa450edef68
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ffabf9ba
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ffabf9ba
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ffabf9ba
Branch: refs/heads/master
Commit: ffabf9ba9b70baa679cca6cf804ef4ec275fdccc
Parents: 72ba786
Author: Devaraj Das <dd...@apache.org>
Authored: Fri Mar 14 07:01:04 2014 +0000
Committer: Enis Soztutar <en...@apache.org>
Committed: Fri Jun 27 16:39:39 2014 -0700
----------------------------------------------------------------------
.../java/org/apache/hadoop/hbase/util/MultiThreadedReader.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/ffabf9ba/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedReader.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedReader.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedReader.java
index e6d4807..df0d3f8 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedReader.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedReader.java
@@ -206,7 +206,7 @@ public class MultiThreadedReader extends MultiThreadedAction
numKeys++;
} while (numKeys < batchSize);
- if (numKeys > 1) { //meaning there is some key to read
+ if (numKeys > 0) { //meaning there is some key to read
readKey(keysForThisReader);
// We have verified some unique key(s).
numUniqueKeysVerified.getAndAdd(readingRandomKeyStartIndex == -1 ?