This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 2dc5d6536 [INLONG-5277][Agent] Fix the wrong http method (#5278)
2dc5d6536 is described below
commit 2dc5d6536442156d099902147df28dd679b63306
Author: woofyzhao <[email protected]>
AuthorDate: Fri Jul 29 17:17:38 2022 +0800
[INLONG-5277][Agent] Fix the wrong http method (#5278)
---
.../src/main/java/org/apache/inlong/agent/utils/HttpManager.java | 8 ++++----
.../org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java | 2 +-
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/HttpManager.java
b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/HttpManager.java
index 255dfa9e1..4bc1ccaa5 100644
---
a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/HttpManager.java
+++
b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/HttpManager.java
@@ -122,11 +122,11 @@ public class HttpManager {
*
* @return response
*/
- public String doSendGet(String url) {
+ public String doSendPost(String url) {
try {
- HttpGet get = getHttpGet(url);
- get.addHeader(BasicAuth.BASIC_AUTH_HEADER,
BasicAuth.genBasicAuthCredential(secretId, secretKey));
- CloseableHttpResponse response = httpClient.execute(get);
+ HttpPost post = getHttpPost(url);
+ post.addHeader(BasicAuth.BASIC_AUTH_HEADER,
BasicAuth.genBasicAuthCredential(secretId, secretKey));
+ CloseableHttpResponse response = httpClient.execute(post);
String returnStr = EntityUtils.toString(response.getEntity());
if (returnStr != null && !returnStr.isEmpty()
&& response.getStatusLine().getStatusCode() ==
AGENT_HTTP_SUCCESS_CODE) {
diff --git
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java
index cb0fc4d22..ee72e6808 100755
---
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java
+++
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java
@@ -214,7 +214,7 @@ public class ManagerFetcher extends AbstractDaemon
implements ProfileFetcher {
* request manager to get manager vipUrl list, and store it to local file
*/
public void requestTdmList() {
- JsonObject result =
getResultData(httpManager.doSendGet(managerVipUrl));
+ JsonObject result =
getResultData(httpManager.doSendPost(managerVipUrl));
JsonArray data =
result.get(AGENT_MANAGER_RETURN_PARAM_DATA).getAsJsonArray();
List<String> managerIpList = new ArrayList<>();
for (JsonElement datum : data) {