-
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
HDFS-16210. RBF: Add the option of refreshCallQueue to RouterAdmin #3379
Conversation
@goiri Could you help to review this PR? |
💔 -1 overall
This message was automatically generated. |
🎊 +1 overall
This message was automatically generated. |
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.
@symious Thanks for contribution, it makes sense. Some minor comments
try (RefreshCallQueueProtocolClientSideTranslatorPB xlator = | ||
new RefreshCallQueueProtocolClientSideTranslatorPB(proxy)) { | ||
xlator.refreshCallQueue(); | ||
System.out.println("Refresh call queue successful for " + hostport); |
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.
here successfully?the bellow should be unsuccessfully?
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.
@ferhui Thanks for the review.
Just to be sure, do you mean changing "successful" to "successfully" and "failed" to "unsuccessfully"?
Borrowed from DFSAdmin, but the changes are good to me.
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.
Uh, it's not my native language. Maybe adverb is more suitable here.
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.
Sure, updated.
System.setOut(new PrintStream(out)); | ||
String[] argv = new String[]{"-refreshCallQueue"}; | ||
assertEquals(0, ToolRunner.run(admin, argv)); | ||
assertTrue(out.toString().contains("Refresh call queue successful")); |
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.
And here.
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.
+1
🎊 +1 overall
This message was automatically generated. |
@symious Could you please change the title of PR and JIRA to "RBF: Add xxx", it means that it's for RBF and it convenient for others to track RBF |
Sure, updated. |
@symious Thanks. Will commit if no other comments. |
Description of PR
We enabled FairCallQueue to RouterRpcServer, but Router can not refreshCallQueue as NameNode does.
This ticket is to enable the refreshCallQueue for Router so that we don't have to restart the Routers when updating FairCallQueue configurations.
The option is not to refreshCallQueue to NameNodes, just trying to refresh the callQueue of Router itself.
Jira ticket: https://issues.apache.org/jira/browse/HDFS-16210
How was this patch tested?
Unit test
For code changes:
LICENSE
,LICENSE-binary
,NOTICE-binary
files?