[accumulo] branch 1.10 updated: Apply timeoutMillis to socket.connect() (#2459) (#2464)

[mmiller]

This is an automated email from the ASF dual-hosted git repository.

mmiller pushed a commit to branch 1.10
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/1.10 by this push:
     new aefff97  Apply timeoutMillis to socket.connect() (#2459) (#2464)
aefff97 is described below

commit aefff9773cc9f4ea03b16fcbdd74da59796c8b55
Author: FineAndDandy <cwilliams.w...@gmail.com>
AuthorDate: Fri Feb 4 07:03:06 2022 -0500

    Apply timeoutMillis to socket.connect() (#2459) (#2464)
---
 core/src/main/java/org/apache/accumulo/core/rpc/TTimeoutTransport.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/core/src/main/java/org/apache/accumulo/core/rpc/TTimeoutTransport.java 
b/core/src/main/java/org/apache/accumulo/core/rpc/TTimeoutTransport.java
index 87a1f24..d39b183 100644
--- a/core/src/main/java/org/apache/accumulo/core/rpc/TTimeoutTransport.java
+++ b/core/src/main/java/org/apache/accumulo/core/rpc/TTimeoutTransport.java
@@ -71,7 +71,7 @@ public class TTimeoutTransport {
       socket = SelectorProvider.provider().openSocketChannel().socket();
       socket.setSoLinger(false, 0);
       socket.setTcpNoDelay(true);
-      socket.connect(addr);
+      socket.connect(addr, (int) timeoutMillis);
       InputStream input = new BufferedInputStream(getInputStream(socket, 
timeoutMillis), 1024 * 10);
       OutputStream output =
           new BufferedOutputStream(NetUtils.getOutputStream(socket, 
timeoutMillis), 1024 * 10);