HBASE-18796 Addendum: Scanner returning null incorrectly during locateRegionInMeta retry, resulting in incorrect TableNotFoundException
Signed-off-by: Andrew Purtell <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/21a61ad5 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/21a61ad5 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/21a61ad5 Branch: refs/heads/HBASE-18467 Commit: 21a61ad597bbc1d15cf2aa44fa9307b580f76c38 Parents: 11d7495 Author: Abhishek Singh Chouhan <[email protected]> Authored: Fri Sep 22 20:20:23 2017 +0530 Committer: Andrew Purtell <[email protected]> Committed: Fri Sep 22 10:20:29 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/21a61ad5/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)) {
