-
Notifications
You must be signed in to change notification settings - Fork 9.2k
YARN-11332. [Federation] Improve FederationClientInterceptor#ThreadPool thread pool configuration. #4982
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
…ol thread pool configuration.
|
💔 -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. |
|
|
||
| <property> | ||
| <name>yarn.router.interceptor.user-thread-pool.keep-alive-time</name> | ||
| <value>10s</value> |
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.
The default used to be 0, we shouldn't change it.
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 suggestion, I will fix it.
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/resources/yarn-default.xml
Show resolved
Hide resolved
|
🎊 +1 overall
This message was automatically generated. |
|
@goiri Can you help review the code again? Thank you very much! |
|
🎊 +1 overall
This message was automatically generated. |
...hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/conf/YarnConfiguration.java
Show resolved
Hide resolved
|
🎊 +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. |
|
💔 -1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
| // If the user configures YarnConfiguration.ROUTER_USER_CLIENT_THREADS_SIZE, | ||
| // we will still get the number of threads from this configuration. | ||
| if (StringUtils.isNotBlank(threadSize)) { | ||
| LOG.warn("{} is an deprecated property, " + |
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.
"a deprecated"
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 a lot for your help reviewing the code, I'll fix it.
| return Integer.parseInt(threadSize); | ||
| } | ||
|
|
||
| int numMinThreads = getConf().getInt( |
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 conf.getInt()?
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'll fix it.
| // If the user configures YarnConfiguration.ROUTER_USER_CLIENT_THREADS_SIZE, | ||
| // we will still get the number of threads from this configuration. | ||
| if (StringUtils.isNotBlank(threadSize)) { | ||
| LOG.warn("{} is an deprecated property, " + |
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.
"a deprecated"
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'll fix it.
| return Integer.parseInt(threadSize); | ||
| } | ||
|
|
||
| int numMaxThreads = getConf().getInt( |
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.
conf
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'll fix it.
|
🎊 +1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
@goiri Thank you very much for helping to review the code! |
JIRA: YARN-11332. [Federation] Improve FederationClientInterceptor#ThreadPool thread pool configuration.
[Federation] Improve FederationClientInterceptor#ThreadPool thread pool configuration.
When we configure deprecated properties, we get hints from the logs: