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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
