Revert "Switch the default registry to ZK based"
This reverts commit 558ee079fd
because
it was not tagged with a jira ID. Will be re-applied.
This commit is contained in:
parent
436567e34d
commit
b33c200a28
|
@ -36,7 +36,7 @@ final class ConnectionRegistryFactory {
|
||||||
*/
|
*/
|
||||||
static ConnectionRegistry getRegistry(Configuration conf) {
|
static ConnectionRegistry getRegistry(Configuration conf) {
|
||||||
Class<? extends ConnectionRegistry> clazz = conf.getClass(
|
Class<? extends ConnectionRegistry> clazz = conf.getClass(
|
||||||
CLIENT_CONNECTION_REGISTRY_IMPL_CONF_KEY, ZKConnectionRegistry.class,
|
CLIENT_CONNECTION_REGISTRY_IMPL_CONF_KEY, MasterRegistry.class,
|
||||||
ConnectionRegistry.class);
|
ConnectionRegistry.class);
|
||||||
return ReflectionUtils.newInstance(clazz, conf);
|
return ReflectionUtils.newInstance(clazz, conf);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue