diff --git a/client/secureclient/src/main/java/com/linkedin/openhouse/client/ssl/WebClientFactory.java b/client/secureclient/src/main/java/com/linkedin/openhouse/client/ssl/WebClientFactory.java index 79bb2dc19..185fc14b5 100644 --- a/client/secureclient/src/main/java/com/linkedin/openhouse/client/ssl/WebClientFactory.java +++ b/client/secureclient/src/main/java/com/linkedin/openhouse/client/ssl/WebClientFactory.java @@ -116,10 +116,10 @@ private HttpClient createHttpClient(String baseUrl) { HttpClient client = null; if (HttpConnectionStrategy.NEW.equals(strategy)) { log.info("Using new connection strategy"); - client = HttpClient.newConnection(); + client = HttpClient.newConnection().disableRetry(true); } else { log.info("Using connection pool strategy"); - client = HttpClient.create(getCustomConnectionProvider()); + client = HttpClient.create(getCustomConnectionProvider()).disableRetry(true); } return client; } @@ -144,11 +144,15 @@ private HttpClient createSecureHttpClient(String truststoreLocation) { HttpClient client = null; if (HttpConnectionStrategy.NEW.equals(strategy)) { log.info("Using new connection strategy"); - client = HttpClient.newConnection().secure(t -> t.sslContext(createSslContext(truststore))); + client = + HttpClient.newConnection() + .disableRetry(true) + .secure(t -> t.sslContext(createSslContext(truststore))); } else { log.info("Using connection pool strategy"); client = HttpClient.create(getCustomConnectionProvider()) + .disableRetry(true) .secure(t -> t.sslContext(createSslContext(truststore))); }