-
Notifications
You must be signed in to change notification settings - Fork 13.8k
[FLINK-33532][rpc] Support configured akka remote dispatcher thread pool size #23707
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
c4d0378 to
1948e49
Compare
| .build()); | ||
|
|
||
| public static final ConfigOption<Double> REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR = | ||
| ConfigOptions.key("akka.remote-fork-join-executor.parallelism-factor") |
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.
pekko
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.
same as below
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.
revised
| /** | ||
| * The raw value that is not offloaded to the {@link org.apache.flink.runtime.blob.BlobServer}. | ||
| * | ||
| * @param <T> type of the serialized 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.
type of the raw 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.
Revised
9da1b9e to
89aff66
Compare
…up out of the RPC main thread]
What is the purpose of the change
Brief change log
akka.remote-fork-join-executor.parallelism-factor,akka.remote-fork-join-executor.parallelism-maxandakka.remote-fork-join-executor.parallelism-minVerifying this change
getConfigDefaultsToRemoteForkJoinExecutorinPekkoUtilsTest.ShuffleDescriptorGrouphave already been covered by existing tests, such asTaskDeploymentDescriptorFactoryTest.Does this pull request potentially affect one of the following parts:
@Public(Evolving): (yes / no)Documentation