-
Notifications
You must be signed in to change notification settings - Fork 8.9k
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
YARN-11537. [Addendum][Federation] Router CLI Supports List SubClusterPolicyConfiguration Of Queues. #6121
Conversation
…rPolicyConfiguration Of Queues.
🎊 +1 overall
This message was automatically generated. |
int totalPage = | ||
(totalSize % pageSize == 0) ? totalSize / pageSize : (totalSize / pageSize) + 1; | ||
|
||
// Step3. Returns the Queue Policies result. | ||
return QueryFederationQueuePoliciesResponse.newInstance( | ||
totalSize, totalPage, currentPage, pageSize, subFederationQueueWeights); | ||
totalSize, totalPage, currentPage, pageSize, subFederationQueueWeights); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Avoid
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for your suggestion! I will fix it.
🎊 +1 overall
This message was automatically generated. |
policiesConfigurations.entrySet()) { | ||
String queue = entry.getKey(); | ||
SubClusterPolicyConfiguration policyConf = entry.getValue(); | ||
if(policyConf == null) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Spacing.
In any case, I think we should do:
if (policyConf != null) {
FederationQueueWeight federationQueueWeight = parseFederationQueueWeight(queue, policyConf);
if (federationQueueWeight != null) {
federationQueueWeights.add(federationQueueWeight);
}
}
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for your suggestion! I will improve this part of the code.
🎊 +1 overall
This message was automatically generated. |
@goiri Thank you very much for your help in reviewing the code! I will continue to improve the function of router command. I will merge this PR into the trunk branch. |
…rPolicyConfiguration Of Queues. (apache#6121) Contributed by Shilun Fan. Reviewed-by: Inigo Goiri <[email protected]> Signed-off-by: Shilun Fan <[email protected]>
Description of PR
JIRA: YARN-11537. [Addendum][Federation] Router CLI Supports List SubClusterPolicyConfiguration Of Queues.
In YARN-11537, we introduced the functionality to list policies, but we require user input for filtering conditions. In this PR, we are extending this feature to allow users to retrieve records even when they do not provide filtering criteria.
How was this patch tested?
Add Junit Test.
For code changes:
LICENSE
,LICENSE-binary
,NOTICE-binary
files?