You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2017/09/22 17:36:57 UTC
[2/4] hbase git commit: HBASE-18796 Addendum: Scanner returning null
incorrectly during locateRegionInMeta retry,
resulting in incorrect TableNotFoundException
HBASE-18796 Addendum: Scanner returning null incorrectly during locateRegionInMeta retry, resulting in incorrect TableNotFoundException
Signed-off-by: Andrew Purtell <ap...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2f18d9e1
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2f18d9e1
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2f18d9e1
Branch: refs/heads/branch-1
Commit: 2f18d9e1559387eef9747c9fbda31534a8ec6f1f
Parents: c0b6aa5
Author: Abhishek Singh Chouhan <ac...@apache.org>
Authored: Fri Sep 22 20:35:19 2017 +0530
Committer: Andrew Purtell <ap...@apache.org>
Committed: Fri Sep 22 10:20:46 2017 -0700
----------------------------------------------------------------------
.../java/org/apache/hadoop/hbase/client/ConnectionManager.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/2f18d9e1/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionManager.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionManager.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionManager.java
index 6227a15..8204bb8 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionManager.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionManager.java
@@ -1275,7 +1275,7 @@ class ConnectionManager {
Scan s = new Scan();
s.setReversed(true);
s.withStartRow(metaKey);
- s.setOneRowLimit();
+
if (this.useMetaReplicas) {
s.setConsistency(Consistency.TIMELINE);
}
@@ -1305,6 +1305,7 @@ class ConnectionManager {
try {
Result regionInfoRow = null;
s.resetMvccReadPoint();
+ s.setOneRowLimit();
try (ReversedClientScanner rcs =
new ReversedClientScanner(conf, s, TableName.META_TABLE_NAME, this, rpcCallerFactory,
rpcControllerFactory, getMetaLookupPool(),