GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2095
[FLINK-4046] [runtime] Add direct state transition from RESTARTING to FAILED
A job can get stuck in FAILING if fail is called on a restarting job which
has
not yet reset its ExecutionJobVertices, because these vertices would not
call
jobVertexInFinalState. This method, however, must be called in order to
transition
from FAILING to FAILED. In order to solve the problem, this PR introduces a
direct
state transition from `RESTARTING` to `FAILED`, if `fail` is called when
being in state
`RESTARTING`.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tillrohrmann/flink fixFailWhileRestarting
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2095.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 #2095
----
commit 094c6b59eb92cb5a0f3bf41aa92aab399ba4127c
Author: Till Rohrmann <[email protected]>
Date: 2016-06-09T13:54:01Z
[FLINK-4046] [runtime] Add direct state transition from RESTARTING to FAILED
A job can get stuck in FAILING if fail is called on a restarting job which
has
not yet reset its ExecutionJobVertices, because these vertices would not
call
jobVertexInFinalState. This method, however, must be called in order to
transition
from FAILING to FAILED.
----
---
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.
---
