[Fix] Fix error with Transfer-encoding header already present (#525)

apache · Jan 6, 2025 · 3ffb6e6 · 3ffb6e6
1 parent 1023235
commit 3ffb6e6
Showing 1 changed file with 3 additions and 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
@@ -25,6 +25,7 @@
 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 @@ protected boolean isRedirectable(String method) {
                                 RequestConfig.custom()
                                         .setConnectTimeout(connectTimeout)
                                         .setConnectionRequestTimeout(connectTimeout)
-                                        .build());
+                                        .build())
+                        .addInterceptorLast(new RequestContent(true));
     }
 
     /**