[BUG][Connector-V2][http] fix httpheader cover (apache#5446)

Zhouwen-CN · Sep 11, 2023 · 895e6bb · 895e6bb
1 parent 1c2b34b
commit 895e6bb
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/...c/main/java/org/apache/seatunnel/connectors/seatunnel/http/client/HttpClientProvider.java b/...c/main/java/org/apache/seatunnel/connectors/seatunnel/http/client/HttpClientProvider.java
@@ -404,7 +404,17 @@ private void addHeaders(HttpRequestBase request, Map<String, String> headers) {
         headers.forEach(request::addHeader);
     }
 
+    private boolean checkAlreadyHaveContentType(HttpEntityEnclosingRequestBase request) {
+        if (request.getEntity() != null && request.getEntity().getContentType() != null) {
+            return HTTP.CONTENT_TYPE.equals(request.getEntity().getContentType().getName());
+        }
+        return false;
+    }
+
     private void addBody(HttpEntityEnclosingRequestBase request, String body) {
+        if (checkAlreadyHaveContentType(request)) {
+            return;
+        }
         request.addHeader(HTTP.CONTENT_TYPE, APPLICATION_JSON);
 
         if (StringUtils.isBlank(body)) {