You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2021/07/09 01:47:11 UTC
[incubator-inlong] branch master updated: [INLONG-673] add tube
cluster id in inlong-manager (#526)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 17f6e08 [INLONG-673] add tube cluster id in inlong-manager (#526)
17f6e08 is described below
commit 17f6e0826a8136b7e80c2ed76e22ad1e8266bdde
Author: healchow <he...@gmail.com>
AuthorDate: Fri Jul 9 09:47:03 2021 +0800
[INLONG-673] add tube cluster id in inlong-manager (#526)
Co-authored-by: healzhou <he...@tencent.com>
---
.../manager/service/thirdpart/mq/TubeMqOptService.java | 13 ++++++-------
1 file changed, 6 insertions(+), 7 deletions(-)
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdpart/mq/TubeMqOptService.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdpart/mq/TubeMqOptService.java
index b4cc0a7..cfd3da8 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdpart/mq/TubeMqOptService.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdpart/mq/TubeMqOptService.java
@@ -62,15 +62,14 @@ public class TubeMqOptService {
.build();
String tubeManager = clusterBean.getTubeManager();
- TubeManagerResponse response = httpUtils
- .request(tubeManager + "/v1/topic?method=queryCanWrite", HttpMethod.POST,
- GSON.toJson(topicRequest), httpHeaders, TubeManagerResponse.class);
+ TubeManagerResponse response = httpUtils.request(tubeManager + "/v1/topic?method=queryCanWrite",
+ HttpMethod.POST, GSON.toJson(topicRequest), httpHeaders, TubeManagerResponse.class);
if (response.getErrCode() == 101) { // topic already exists
- log.info(" create tube topic {} on {} ", GSON.toJson(request),
+ log.info("create tube topic {} on {} ", GSON.toJson(request),
tubeManager + "/v1/task?method=addTopicTask");
- TubeManagerResponse createRsp = httpUtils
- .request(tubeManager + "/v1/task?method=addTopicTask", HttpMethod.POST,
- GSON.toJson(request), httpHeaders, TubeManagerResponse.class);
+ request.setClusterId(clusterBean.getClusterId());
+ httpUtils.request(tubeManager + "/v1/task?method=addTopicTask", HttpMethod.POST,
+ GSON.toJson(request), httpHeaders, TubeManagerResponse.class);
} else {
log.warn("topic {} exists in {} ", addTopicTasksBean.getTopicName(), tubeManager);
}