diff --git a/pom.xml b/pom.xml index dbd8b1c2f3..34ce6876a4 100644 --- a/pom.xml +++ b/pom.xml @@ -63,7 +63,7 @@ https://repository.apache.org/service/local/staging/deploy/maven2 - 2.16.1 + 3.0.14 1.82 1.8 1.1 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();