HBASE-29191 Use MetaRpcReadTimeout when accessing Meta replicas

Author: Yiran-wu

Diff for: hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncNonMetaRegionLocator.java

@@ -234,7 +234,7 @@ private boolean tryComplete(LocateRequest req, CompletableFuture<RegionLocations
             int numOfReplicas = CatalogReplicaLoadBalanceSelector.UNINITIALIZED_NUM_OF_REPLICAS;
             try {
               RegionLocations metaLocations = conn.registry.getMetaRegionLocations()
-                .get(conn.connConf.getReadRpcTimeoutNs(), TimeUnit.NANOSECONDS);
+                .get(conn.connConf.getMetaReadRpcTimeoutNs(), TimeUnit.NANOSECONDS);
               numOfReplicas = metaLocations.size();
             } catch (Exception e) {
               LOG.error("Failed to get table {}'s region replication, ", META_TABLE_NAME, e);

Diff for: hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java

@@ -411,7 +411,7 @@ public void newDead(ServerName sn) {
             int numOfReplicas = 1;
             try {
               RegionLocations metaLocations = this.registry.getMetaRegionLocations()
-                .get(connectionConfig.getReadRpcTimeout(), TimeUnit.MILLISECONDS);
+                .get(connectionConfig.getMetaReadRpcTimeout(), TimeUnit.MILLISECONDS);
               numOfReplicas = metaLocations.size();
             } catch (Exception e) {
               LOG.error("Failed to get table {}'s region replication, ", META_TABLE_NAME, e);

Diff for: hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestCatalogReplicaLoadBalanceSimpleSelector.java

@@ -99,7 +99,7 @@ public void testMetaChangeFromReplicaNoReplica() throws IOException, Interrupted
         int numOfReplicas = CatalogReplicaLoadBalanceSelector.UNINITIALIZED_NUM_OF_REPLICAS;
         try {
           RegionLocations metaLocations = CONN.registry.getMetaRegionLocations()
-            .get(CONN.connConf.getReadRpcTimeoutNs(), TimeUnit.NANOSECONDS);
+            .get(CONN.connConf.getMetaReadRpcTimeoutNs(), TimeUnit.NANOSECONDS);
           numOfReplicas = metaLocations.size();
         } catch (Exception e) {
           LOG.error("Failed to get table {}'s region replication, ", META_TABLE_NAME, e);
@@ -126,7 +126,7 @@ public void testMetaChangeFromReplicaNoReplica() throws IOException, Interrupted
           int numOfReplicas = CatalogReplicaLoadBalanceSelector.UNINITIALIZED_NUM_OF_REPLICAS;
           try {
             RegionLocations metaLocations = CONN.registry.getMetaRegionLocations()
-              .get(CONN.connConf.getReadRpcTimeoutNs(), TimeUnit.NANOSECONDS);
+              .get(CONN.connConf.getMetaReadRpcTimeoutNs(), TimeUnit.NANOSECONDS);
             numOfReplicas = metaLocations.size();
           } catch (Exception e) {
             LOG.error("Failed to get table {}'s region replication, ", META_TABLE_NAME, e);