Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[INLONG-9222][Manager] Support sortstandalone get cluster config with multiple cluster tag #9262

Closed
wants to merge 12 commits into from

Conversation

castorqin
Copy link
Contributor

Prepare a Pull Request

(Change the title refer to the following example)

  • Title Example: [INLONG-XYZ][Component] Title of the pull request

(The following XYZ should be replaced by the actual GitHub Issue number)

Motivation

  • sortstandalone get sort cluster config support multiple cluster tag
  • fix pulsar cluster don't have authentication info,sortstandalone can't send message

Modifications

The details can be found at #9222 .

}
return Arrays.asList(clusterTags.split(InlongConstants.COMMA));
}

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

make a clusterTagsSet, and init it when the first time you use it.

return true;
}
return sortClusterTag.equals(groupInfos.get(sink.getGroupId()).getClusterTag());
return sortClusterTags.contains(groupInfos.get(sink.getGroupId()).getClusterTag());
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Use set instead of list

# Conflicts:
#	inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/AbstractDataNodeOperator.java
@vernedeng vernedeng marked this pull request as draft December 5, 2023 02:12
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[Bug][Manager] When cluster have multiple cluster tag,manager return wrong metadata info
3 participants