From abae931f96547de339884891cb1aeb05eebf97ac Mon Sep 17 00:00:00 2001
From: Dmitriy Fingerman <dfingerman@cloudera.com>
Date: Thu, 5 Nov 2026 18:03:22 -0600
Subject: [PATCH] TEZ-4761: Addendum: Upgrade asynchttpclient version to
 3.0.14.

---
 pom.xml                                                        | 2 +-
 .../org/apache/tez/http/async/netty/AsyncHttpConnection.java   | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/pom.xml b/pom.xml
index dbd8b1c2f3..34ce6876a4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -63,7 +63,7 @@
     <distMgmtStagingUrl>https://repository.apache.org/service/local/staging/deploy/maven2</distMgmtStagingUrl>
 
     <!--dependency versions in alphabetical order-->
-    <asynchttpclient.version>2.16.1</asynchttpclient.version>
+    <asynchttpclient.version>3.0.14</asynchttpclient.version>
     <bouncycastle.version>1.82</bouncycastle.version>
     <build-helper-maven-plugin.version>1.8</build-helper-maven-plugin.version>
     <buildnumber-maven-plugin.version>1.1</buildnumber-maven-plugin.version>
diff --git a/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/AsyncHttpConnection.java b/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/AsyncHttpConnection.java
index 3806acc576..43b4697f41 100644
--- a/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/AsyncHttpConnection.java
+++ b/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/AsyncHttpConnection.java
@@ -24,6 +24,7 @@
 import java.io.PipedOutputStream;
 import java.net.HttpURLConnection;
 import java.net.URL;
+import java.time.Duration;
 import java.util.concurrent.TimeUnit;
 
 import org.apache.commons.io.IOUtils;
@@ -100,7 +101,7 @@ private void initClient(HttpConnectionParams httpConnParams) throws IOException
               //.setExecutorService(applicationThreadPool)
               //.addRequestFilter(new ThrottleRequestFilter(1))
               .setMaxConnectionsPerHost(1)
-              .setConnectTimeout(httpConnParams.getConnectionTimeout())
+              .setConnectTimeout(Duration.ofMillis(httpConnParams.getConnectionTimeout()))
               .setDisableUrlEncodingForBoundRequests(true)
               .build();
           DefaultAsyncHttpClientConfig config = builder.build();