You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2021/08/20 07:35:37 UTC
[hbase] branch master updated: HBASE-26174 Make rpc connection
registry the default registry on 3.0.0 (#3600)
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/master by this push:
new 28d81ae HBASE-26174 Make rpc connection registry the default registry on 3.0.0 (#3600)
28d81ae is described below
commit 28d81ae44f61d356e2c1e25d7cb1372311c70417
Author: Duo Zhang <zh...@apache.org>
AuthorDate: Fri Aug 20 15:35:07 2021 +0800
HBASE-26174 Make rpc connection registry the default registry on 3.0.0 (#3600)
Signed-off-by: Bharath Vissapragada <bh...@apache.org>
---
.../org/apache/hadoop/hbase/client/ConnectionRegistryFactory.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionRegistryFactory.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionRegistryFactory.java
index 3879d00..92c075c 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionRegistryFactory.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionRegistryFactory.java
@@ -18,6 +18,7 @@
package org.apache.hadoop.hbase.client;
import static org.apache.hadoop.hbase.HConstants.CLIENT_CONNECTION_REGISTRY_IMPL_CONF_KEY;
+
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.util.ReflectionUtils;
import org.apache.yetus.audience.InterfaceAudience;
@@ -35,8 +36,9 @@ final class ConnectionRegistryFactory {
* @return The connection registry implementation to use.
*/
static ConnectionRegistry getRegistry(Configuration conf) {
- Class<? extends ConnectionRegistry> clazz = conf.getClass(
- CLIENT_CONNECTION_REGISTRY_IMPL_CONF_KEY, MasterRegistry.class, ConnectionRegistry.class);
+ Class<? extends ConnectionRegistry> clazz =
+ conf.getClass(CLIENT_CONNECTION_REGISTRY_IMPL_CONF_KEY, RpcConnectionRegistry.class,
+ ConnectionRegistry.class);
return ReflectionUtils.newInstance(clazz, conf);
}
}