You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/08/24 07:24:24 UTC
[incubator-seatunnel] branch dev updated: [Bug][Connector-V2] Fix the bug that set params by mistake (#2511) (#2513)
This is an automated email from the ASF dual-hosted git repository.
kirs 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 ead3d68b0 [Bug][Connector-V2] Fix the bug that set params by mistake (#2511) (#2513)
ead3d68b0 is described below
commit ead3d68b0e8bf66c49e895ec127865821884e396
Author: Bruce Lee <54...@qq.com>
AuthorDate: Wed Aug 24 15:24:18 2022 +0800
[Bug][Connector-V2] Fix the bug that set params by mistake (#2511) (#2513)
Co-authored-by: litz-a <li...@glodon.com>
---
.../seatunnel/connectors/seatunnel/http/config/HttpParameter.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/config/HttpParameter.java b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpParameter.java
index 53f1161fd..c22a24849 100644
--- a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpParameter.java
+++ b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpParameter.java
@@ -47,7 +47,7 @@ public class HttpParameter implements Serializable {
}
// set params
if (pluginConfig.hasPath(HttpConfig.PARAMS)) {
- this.setHeaders(pluginConfig.getConfig(HttpConfig.PARAMS).entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, entry -> String.valueOf(entry.getValue().unwrapped()), (v1, v2) -> v2)));
+ this.setParams(pluginConfig.getConfig(HttpConfig.PARAMS).entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, entry -> String.valueOf(entry.getValue().unwrapped()), (v1, v2) -> v2)));
}
// set body
if (pluginConfig.hasPath(HttpConfig.BODY)) {