dlmarion commented on code in PR #4880:
URL: https://github.com/apache/accumulo/pull/4880#discussion_r1758839515
##########
core/src/main/java/org/apache/accumulo/core/rpc/clients/TServerClient.java:
##########
@@ -113,6 +129,9 @@ default Pair<String,C> getThriftServerConnection(Logger
LOG, ThriftClientTypes<C
TTransport transport =
context.getTransportPool().getTransport(type,
tserverClientAddress, rpcTimeout, context,
preferCachedConnections);
C client = ThriftUtil.createClient(type, transport);
+ if (type == ThriftClientTypes.CLIENT && preferredClientHost !=
null) {
Review Comment:
Added more logging in ae80003.
##########
core/src/main/java/org/apache/accumulo/core/rpc/clients/TServerClient.java:
##########
@@ -54,6 +54,8 @@
public interface TServerClient<C extends TServiceClient> {
+ static final String PREFERRED_HOST =
"org.apache.accumulo.client.rpc.preferred.host";
+
Pair<String,C> getThriftServerConnection(ClientContext context, boolean
preferCachedConnections)
Review Comment:
IT added in ae80003.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
