GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/3474
[FLINK-4714] [runtime] [streaming] Set task state to RUNNING after state
has been restored
The changes in this PR are
- add `open()` method in `AbstractInvokable` to let the invokable can be
initialized during `DEPLOYING` state in `Task`. The default behavior is do
nothing.
- separate `invokable.invoke()` into `invokable.open()` and
`invokable.invoke()` in `Task`, and transit task state from `DEPLOYING` to
`RUNNING` between them.
- `TaskCanceler` should be used to cancel the invokable in `DEPLOYING`
state because invokable might be called in that state now.
- update `StreamTask` and `StreamTaskTestHarness` to solve this issue in
FLINK-4714
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tony810430/flink FLINK-4714
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3474.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 #3474
----
commit baa0285ce481db0f96d59ed71d86f81b1f5fcd65
Author: Tony Wei <tony19920...@gmail.com>
Date: 2017-03-03T08:46:22Z
[FLINK-4714] Set task state to RUNNING after state has been restored
----
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
