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