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:59 UTC
[4/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/8df523bd
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8df523bd
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8df523bd
Branch: refs/heads/branch-2
Commit: 8df523bdd0d03f32a189fe39bee27380095e1a47
Parents: a9fcd95
Author: Abhishek Singh Chouhan <ac...@apache.org>
Authored: Fri Sep 22 20:20:23 2017 +0530
Committer: Andrew Purtell <ap...@apache.org>
Committed: Fri Sep 22 10:21:06 2017 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/hbase/client/ConnectionImplementation.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/8df523bd/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java
index 036f597..860eef3 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java
@@ -805,7 +805,7 @@ class ConnectionImplementation implements ClusterConnection, Closeable {
s.setReversed(true);
s.withStartRow(metaKey);
s.addFamily(HConstants.CATALOG_FAMILY);
- s.setOneRowLimit();
+
if (this.useMetaReplicas) {
s.setConsistency(Consistency.TIMELINE);
}
@@ -835,6 +835,7 @@ class ConnectionImplementation implements ClusterConnection, Closeable {
try {
Result regionInfoRow = null;
s.resetMvccReadPoint();
+ s.setOneRowLimit();
try (ReversedClientScanner rcs =
new ReversedClientScanner(conf, s, TableName.META_TABLE_NAME, this, rpcCallerFactory,
rpcControllerFactory, getMetaLookupPool(), metaReplicaCallTimeoutScanInMicroSecond)) {