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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 87bf8a23b1 [Fix][Connector-V2][Http]Fix setting of HTTP parameters in 
HttpSink.java (#10053)
87bf8a23b1 is described below

commit 87bf8a23b10b78934da835aae5f3cb724f5e3895
Author: Jast <[email protected]>
AuthorDate: Wed Nov 12 21:11:13 2025 +0800

    [Fix][Connector-V2][Http]Fix setting of HTTP parameters in HttpSink.java 
(#10053)
---
 .../org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java
 
b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java
index c19c2b18c7..d6ab48aa87 100644
--- 
a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java
+++ 
b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java
@@ -45,7 +45,7 @@ public class HttpSink extends 
AbstractSimpleSink<SeaTunnelRow, Void>
             
httpParameter.setHeaders(pluginConfig.get(HttpSinkOptions.HEADERS));
         }
         if (pluginConfig.getOptional(HttpSinkOptions.PARAMS).isPresent()) {
-            httpParameter.setHeaders(pluginConfig.get(HttpSinkOptions.PARAMS));
+            httpParameter.setParams(pluginConfig.get(HttpSinkOptions.PARAMS));
         }
         if (pluginConfig.getOptional(HttpSinkOptions.ARRAY_MODE).isPresent()) {
             
httpParameter.setArrayMode(pluginConfig.get(HttpSinkOptions.ARRAY_MODE));

Reply via email to