You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/03/30 02:49:45 UTC
[incubator-inlong] branch master updated: [INLONG-3451][Manager] Got wrong results when querying tube cluster info (#3452)
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/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new d7896d2 [INLONG-3451][Manager] Got wrong results when querying tube cluster info (#3452)
d7896d2 is described below
commit d7896d2ad9bb9454d19f7ee576ab1bc19889beca
Author: ciscozhou <45...@users.noreply.github.com>
AuthorDate: Wed Mar 30 10:49:39 2022 +0800
[INLONG-3451][Manager] Got wrong results when querying tube cluster info (#3452)
---
.../java/org/apache/inlong/manager/service/CommonOperateService.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/CommonOperateService.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/CommonOperateService.java
index 65a29d7..ba9a9a4 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/CommonOperateService.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/CommonOperateService.java
@@ -113,7 +113,7 @@ public class CommonOperateService {
case Constant.CLUSTER_TUBE_MANAGER:
case Constant.CLUSTER_TUBE_CLUSTER_ID:
case Constant.TUBE_MASTER_URL: {
- clusterEntity = getMQCluster(MQType.PULSAR);
+ clusterEntity = getMQCluster(MQType.TUBE);
if (clusterEntity != null) {
if (key.equals(Constant.TUBE_MASTER_URL)) {
result = clusterEntity.getUrl();
@@ -132,9 +132,6 @@ public class CommonOperateService {
* Get third party cluster by type.
*
* TODO Add data_proxy_cluster_name for query.
- *
- * @param type
- * @return
*/
private ThirdPartyClusterEntity getMQCluster(MQType type) {
List<ThirdPartyClusterEntity> clusterList = thirdPartyClusterMapper.selectByType(Constant.CLUSTER_DATA_PROXY);