GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/3125
[FLINK-5499][JobManager]Reuse the resource location of prior executioâ¦
Currently when schedule execution to request to allocate slot from
**SlotPool**, the **TaskManagerLocation** parameter is empty collection. So for
task fail over scenario, the new execution attempt may be deployed to different
task managers. If setting rockDB as state backend, the performance is better if
the data can be restored from local machine. So we try to reuse the
**TaskManagerLocation** of prior execution attempt when allocating slot from
**SlotPool**. If the **TaskManagerLocation** is empty from prior executions,
the behavior is the same with current status.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/wangzhijiang999/flink FLINK-5499
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3125.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3125
----
commit ab2e24ae7e82be45359f249670f72664226ec18c
Author: æ·æ± <[email protected]>
Date: 2017-01-16T09:28:19Z
[FLINK-5499][JobManager]Reuse the resource location of prior execution
attempt in allocating slot
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
