This is an automated email from the ASF dual-hosted git repository. diwu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push: new c4339a82 [Improve] Fix Httpclient connection in Stream Writer (#399) c4339a82 is described below commit c4339a829411fac792a4a9c6863a14ac0d93a5c9 Author: wudi <676366...@qq.com> AuthorDate: Fri Jun 7 11:13:25 2024 +0800 [Improve] Fix Httpclient connection in Stream Writer (#399) --- .../src/main/java/org/apache/doris/flink/sink/HttpUtil.java | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java index 1307ce40..518eea71 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java @@ -18,6 +18,7 @@ package org.apache.doris.flink.sink; import org.apache.http.client.config.RequestConfig; +import org.apache.http.impl.NoConnectionReuseStrategy; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.DefaultRedirectStrategy; import org.apache.http.impl.client.HttpClientBuilder; @@ -27,6 +28,13 @@ import java.util.concurrent.TimeUnit; /** util to build http client. */ public class HttpUtil { + + private RequestConfig requestConfigStream = + RequestConfig.custom() + .setConnectTimeout(60 * 1000) + .setConnectionRequestTimeout(60 * 1000) + .build(); + private final HttpClientBuilder httpClientBuilder = HttpClients.custom() .setRedirectStrategy( @@ -36,8 +44,10 @@ public class HttpUtil { return true; } }) + .setConnectionReuseStrategy(NoConnectionReuseStrategy.INSTANCE) .evictExpiredConnections() - .evictIdleConnections(60, TimeUnit.SECONDS); + .evictIdleConnections(60, TimeUnit.SECONDS) + .setDefaultRequestConfig(requestConfigStream); public CloseableHttpClient getHttpClient() { return httpClientBuilder.build(); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org