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:58 UTC
[3/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/10a09038
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/10a09038
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/10a09038
Branch: refs/heads/branch-1.4
Commit: 10a090387ac996e2ab2394a2c693de432f82a35f
Parents: 0995607
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:53 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/10a09038/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(),