GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1637
[FLINK-3390] [runtime, tests] Reset Execution state on ExecutionVertex reset
Resuming from a savepoint sets the initial state of the execution graph. If
the restore operation fails on the task managers, the job will be retried with
new executions, which *don't* have their initial state set.
This PR changes the `ExecutionVertex#resetForNewExecution()` behaviour to
reset the state of the `Execution` as well.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/uce/flink 3390-savepoint_retry
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1637.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 #1637
----
commit b1560eff111e249d46a1f7da22a9060c2c9e71a7
Author: Ufuk Celebi <[email protected]>
Date: 2016-02-15T10:43:19Z
[FLINK-3390] [runtime, tests] Reset execution state on ExecutionVertex reset
----
---
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.
---
