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 3ffb6e60 [Fix] Fix error with Transfer-encoding header already present
(#525)
3ffb6e60 is described below
commit 3ffb6e60fc3b647c775ae52bc8a8fa8f98c48413
Author: awol2005ex <[email protected]>
AuthorDate: Mon Jan 6 11:48:41 2025 +0800
[Fix] Fix error with Transfer-encoding header already present (#525)
---
.../src/main/java/org/apache/doris/flink/sink/HttpUtil.java | 4 +++-
1 file changed, 3 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 94b65c79..53d3ce13 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
@@ -25,6 +25,7 @@ import org.apache.http.impl.client.DefaultRedirectStrategy;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.client.HttpClients;
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;
@@ -64,7 +65,8 @@ public class HttpUtil {
RequestConfig.custom()
.setConnectTimeout(connectTimeout)
.setConnectionRequestTimeout(connectTimeout)
- .build());
+ .build())
+ .addInterceptorLast(new RequestContent(true));
}
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
