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 6bbb918d [Fix] remove the socket timeout configuration of httpclient
(#563)
6bbb918d is described below
commit 6bbb918d3c2be79f0a427207201e3947d7d1e0df
Author: wudi <[email protected]>
AuthorDate: Fri Feb 21 18:18:44 2025 +0800
[Fix] remove the socket timeout configuration of httpclient (#563)
---
.../main/java/org/apache/doris/flink/sink/HttpUtil.java | 17 ++++++++++-------
1 file changed, 10 insertions(+), 7 deletions(-)
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 d1600de6..38716826 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
@@ -28,23 +28,22 @@ import org.apache.http.protocol.HttpRequestExecutor;
import org.apache.http.protocol.RequestContent;
import static
org.apache.doris.flink.cfg.ConfigurationOptions.DORIS_REQUEST_CONNECT_TIMEOUT_MS_DEFAULT;
-import static
org.apache.doris.flink.cfg.ConfigurationOptions.DORIS_REQUEST_READ_TIMEOUT_MS_DEFAULT;
/** util to build http client. */
public class HttpUtil {
private final int connectTimeout;
- private final int socketTimeout;
+ private final int waitForContinueTimeout;
private HttpClientBuilder httpClientBuilder;
public HttpUtil() {
this.connectTimeout = DORIS_REQUEST_CONNECT_TIMEOUT_MS_DEFAULT;
- this.socketTimeout = DORIS_REQUEST_READ_TIMEOUT_MS_DEFAULT;
+ this.waitForContinueTimeout = DORIS_REQUEST_CONNECT_TIMEOUT_MS_DEFAULT;
settingStreamHttpClientBuilder();
}
public HttpUtil(DorisReadOptions readOptions) {
this.connectTimeout = readOptions.getRequestConnectTimeoutMs();
- this.socketTimeout = readOptions.getRequestReadTimeoutMs();
+ this.waitForContinueTimeout = readOptions.getRequestConnectTimeoutMs();
settingStreamHttpClientBuilder();
}
@@ -52,7 +51,7 @@ public class HttpUtil {
this.httpClientBuilder =
HttpClients.custom()
// default timeout 3s, maybe report 307 error when fe
busy
- .setRequestExecutor(new
HttpRequestExecutor(socketTimeout))
+ .setRequestExecutor(new
HttpRequestExecutor(waitForContinueTimeout))
.setRedirectStrategy(
new DefaultRedirectStrategy() {
@Override
@@ -97,7 +96,9 @@ public class HttpUtil {
RequestConfig.custom()
.setConnectTimeout(connectTimeout)
.setConnectionRequestTimeout(connectTimeout)
- .setSocketTimeout(socketTimeout)
+ // todo: Need to be extracted to
DorisExecutionOption
+ // default checkpoint timeout is 10min
+ .setSocketTimeout(9 * 60 * 1000)
.build());
}
@@ -108,7 +109,9 @@ public class HttpUtil {
RequestConfig.custom()
.setConnectTimeout(connectTimeout)
.setConnectionRequestTimeout(connectTimeout)
- .setSocketTimeout(socketTimeout)
+ // todo: Need to be extracted to
DorisExecutionOption
+ // default checkpoint timeout is 10min
+ .setSocketTimeout(9 * 60 * 1000)
.build());
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
