[
https://issues.apache.org/jira/browse/FLINK-3390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147196#comment-15147196
]
ASF GitHub Bot commented on FLINK-3390:
---------------------------------------
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
----
> Savepoint resume is not retried
> -------------------------------
>
> Key: FLINK-3390
> URL: https://issues.apache.org/jira/browse/FLINK-3390
> Project: Flink
> Issue Type: Bug
> Reporter: Sebastian Klemke
> Attachments: savepoint_restore_violates_exactly_once.patch
>
>
> When during resuming from a savepoint, restoreState fails for a task node,
> job is retried but without retrying resume from savepoint state. This leads
> to the job being restarted with empty state.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
