Skip to content

Commit

Permalink
[INLONG-9147][Manager] The group details are displayed with the tag o…
Browse files Browse the repository at this point in the history
…f the cluster to which the group belongs (#9148)
  • Loading branch information
fuweng11 authored Oct 30, 2023
1 parent eb5f890 commit 4ffe4ea
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public interface InlongStreamApi {
Call<Response<InlongStreamInfo>> getStream(@Query("groupId") String groupId,
@Query("streamId") String streamId);

@GET("/stream/getBrief")
@GET("stream/getBrief")
Call<Response<InlongStreamBriefInfo>> getStreamBriefInfo(@Query("groupId") String groupId,
@Query("streamId") String streamId);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -132,6 +132,7 @@ public Map<String, Object> getDetailInfo(InlongGroupInfo groupInfo) {
@Override
public Map<String, Object> getClusterInfoByTag(String clusterTag) {
Map<String, Object> clusterMap = new HashMap<>();
clusterMap.put("inlongClusterTag", clusterTag);
Set<String> mqClusters = Sets.newHashSet(ClusterType.PULSAR, ClusterType.TUBEMQ, ClusterType.KAFKA);
List<InlongClusterEntity> clusterEntities = clusterEntityMapper.selectByClusterTag(clusterTag);
for (InlongClusterEntity clusterEntity : clusterEntities) {
Expand Down

0 comments on commit 4ffe4ea

Please sign in to comment.