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));