-
Notifications
You must be signed in to change notification settings - Fork 9.2k
YARN-11484. [Federation] Router Supports Yarn Client CLI Cmds. #6132
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
Conversation
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
@goiri Can you help review this PR? Thank you very much! |
| pw.println("\tWeight : " + "0.30"); | ||
| pw.println("\tState : " + "RUNNING"); | ||
| pw.println("\tMinResource : " + "<memory : 0, vCores:10>"); | ||
| pw.println("\tMaxResource : " + "<memory : 8192, vCores:0>"); |
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.
Why not just a single one without the +?
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.
Thank you very much for your help in reviewing the code! I wrote this unit test based on the original unit test. I will improve this part of the code.
|
|
||
| QueueInfo queueInfo = response.getQueueInfo(); | ||
| Assert.assertNotNull(queueInfo); | ||
| Assert.assertEquals(queueInfo.getQueueName(), "root"); |
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.
Usually expected is first.
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.
I will fix it.
|
🎊 +1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
| writer.print("\tState : "); | ||
| writer.println(queueInfo.getQueueState()); | ||
| writer.print("\tMinResource : "); | ||
| writer.println("<memory : " + queueInfo.getMinResourceMemory() + |
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.
We are doing this operation a lot, we should have some function to generate the String.
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 refactor this part of the code.
|
@goiri Can you help review this PR again? Thank you very much! |
|
🎊 +1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
@goiri Can you help review this PR again? Thank you very much! |
Description of PR
JIRA: YARN-11484. [Federation] Router Supports Yarn Client CLI Cmds.
In YARN Federation, clients connect to the Router, and we need to ensure that basic commands related to applications and queues operate smoothly. We will improve certain commands to help users identify that they are using YARN Federation.
Currently, the 'yarn queue status' command can only display queue information for the CapacityScheduler. In this PR, we are adding the capability to display information for the FairScheduler. Additionally, if the user has enabled Federation mode, it will display Federation-related messages.
Before the modification
These queue details are intended for display with the
CapacityScheduler. If the queue is managed by theFairScheduler, it may not provide meaningful information.After the modification
We present relevant information based on the queue details of the
FairScheduler.How was this patch tested?
For code changes:
LICENSE,LICENSE-binary,NOTICE-binaryfiles?