(doris-flink-connector) branch master updated: [improvement] add http timeout for batch write (#333)

[kirs]

This is an automated email from the ASF dual-hosted git repository.

kirs 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 a758cee  [improvement] add http timeout for batch write (#333)
a758cee is described below

commit a758cee94a30836b0433798d24c47991eb214436
Author: wudi <676366...@qq.com>
AuthorDate: Mon Mar 11 10:03:07 2024 +0800

    [improvement] add http timeout for batch write (#333)
---
 .../src/main/java/org/apache/doris/flink/sink/HttpUtil.java           | 4 ++++
 .../java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java  | 2 +-
 2 files changed, 5 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 d081c40..43e2bea 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
@@ -48,6 +48,10 @@ public class HttpUtil {
                     .setSocketTimeout(9 * 60 * 1000)
                     .build();
 
+    public CloseableHttpClient getHttpClientForBatch() {
+        return 
httpClientBuilder.setDefaultRequestConfig(requestConfig).build();
+    }
+
     private final HttpClientBuilder httpClientBuilderWithTimeout =
             HttpClients.custom().setDefaultRequestConfig(requestConfig);
 
diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java
index f32ce2c..0971be0 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java
@@ -90,7 +90,7 @@ public class DorisBatchStreamLoad implements Serializable {
     private final AtomicBoolean started;
     private volatile boolean loadThreadAlive = false;
     private AtomicReference<Throwable> exception = new AtomicReference<>(null);
-    private CloseableHttpClient httpClient = new HttpUtil().getHttpClient();
+    private CloseableHttpClient httpClient = new 
HttpUtil().getHttpClientForBatch();
     private BackendUtil backendUtil;
 
     public DorisBatchStreamLoad(


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org