HDFS-14170. [SBN read] Fix checkstyle warnings related to SBN reads. Contributed by Konstantin V Shvachko.
This commit is contained in:
parent
720eed9ef9
commit
c936562c72
|
@ -591,7 +591,7 @@ public class RPC {
|
|||
|
||||
/**
|
||||
* Get a protocol proxy that contains a proxy connection to a remote server
|
||||
* and a set of methods that are supported by the server
|
||||
* and a set of methods that are supported by the server.
|
||||
*
|
||||
* @param protocol protocol
|
||||
* @param clientVersion client's version
|
||||
|
|
|
@ -110,7 +110,7 @@ public class ObserverReadProxyProvider<T extends ClientProtocol>
|
|||
public ObserverReadProxyProvider(
|
||||
Configuration conf, URI uri, Class<T> xface, HAProxyFactory<T> factory) {
|
||||
this(conf, uri, xface, factory,
|
||||
new ConfiguredFailoverProxyProvider<>(conf, uri, xface,factory));
|
||||
new ConfiguredFailoverProxyProvider<>(conf, uri, xface, factory));
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
|
@ -144,7 +144,7 @@ public class ObserverReadProxyProvider<T extends ClientProtocol>
|
|||
combinedInfo.append(']');
|
||||
T wrappedProxy = (T) Proxy.newProxyInstance(
|
||||
ObserverReadInvocationHandler.class.getClassLoader(),
|
||||
new Class<?>[] { xface }, new ObserverReadInvocationHandler());
|
||||
new Class<?>[] {xface}, new ObserverReadInvocationHandler());
|
||||
combinedProxy = new ProxyInfo<>(wrappedProxy, combinedInfo.toString());
|
||||
// TODO : make this configurable or remove this variable
|
||||
this.observerReadEnabled = true;
|
||||
|
|
Loading…
Reference in New Issue