[incubator-seatunnel] branch dev updated: [Hotfix][Connector][Doris] Fix Content Length header already present (#4277)

[tyrantlucifer]

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

tyrantlucifer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new df82b7715 [Hotfix][Connector][Doris] Fix Content Length header already 
present (#4277)
df82b7715 is described below

commit df82b77153efca99a2632fdc3c2fcf2789ddbe10
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Mon Mar 6 08:12:24 2023 +0800

    [Hotfix][Connector][Doris] Fix Content Length header already present (#4277)
---
 release-note.md                                                |  1 +
 .../apache/seatunnel/connectors/doris/client/HttpHelper.java   | 10 ++++++++++
 2 files changed, 11 insertions(+)

diff --git a/release-note.md b/release-note.md
index b309cf640..dcf38096c 100644
--- a/release-note.md
+++ b/release-note.md
@@ -59,6 +59,7 @@
 - [ClickHouse] Fix connector source snapshot state NPE #4027
 - [Kudu] Fix connector source snapshot state NPE #4027
 - [Maxcompute] Fix some data type parse fail #3894
+- [Doris] Fix content-length header already present #4277
 
 ### Zeta Engine
 - [Checkpoint] Fix Checkpoint Continue Trigger After Job CANCELED #3808
diff --git 
a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/client/HttpHelper.java
 
b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/client/HttpHelper.java
index e9518e230..bf39f2c7c 100644
--- 
a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/client/HttpHelper.java
+++ 
b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/client/HttpHelper.java
@@ -20,6 +20,7 @@ package org.apache.seatunnel.connectors.doris.client;
 import org.apache.seatunnel.common.utils.JsonUtils;
 
 import org.apache.http.HttpEntity;
+import org.apache.http.HttpRequestInterceptor;
 import org.apache.http.HttpStatus;
 import org.apache.http.client.config.RequestConfig;
 import org.apache.http.client.methods.CloseableHttpResponse;
@@ -30,6 +31,7 @@ import org.apache.http.impl.client.CloseableHttpClient;
 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.HTTP;
 import org.apache.http.util.EntityUtils;
 
 import lombok.extern.slf4j.Slf4j;
@@ -99,6 +101,14 @@ public class HttpHelper {
             throws IOException {
         final HttpClientBuilder httpClientBuilder =
                 HttpClients.custom()
+                        .addInterceptorFirst(
+                                (HttpRequestInterceptor)
+                                        (request, context) -> {
+                                            // fighting 
org.apache.http.protocol.RequestContent's
+                                            // 
ProtocolException("Content-Length header already
+                                            // present");
+                                            
request.removeHeaders(HTTP.CONTENT_LEN);
+                                        })
                         .setRedirectStrategy(
                                 new DefaultRedirectStrategy() {
                                     @Override