GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2710
[FLINK-4932] [exec graph] Failing in state RESTARTING only fails the EG if
no more restarts are possible
If in state RESTARTING a failure occurs (`ExecutionGraph.fail` is called),
then a new restart attempt is started. Only if the restart strategy no longer
allows further restarts or if the thrown exception is of type
`SuppressRestartsException` a job can go from RESTARTING into FAILED.
@StephanEwen would be great if you could review this PR.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tillrohrmann/flink fixRestartingState
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2710.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 #2710
----
commit 9d96a799ee4e0f6b77cf5ae97d270021242a5462
Author: Till Rohrmann <[email protected]>
Date: 2016-10-27T16:32:08Z
[FLINK-4932] [exec graph] Failing in state RESTARTING only fails the EG if
no more restarts are possible
If in state RESTARTING a failure occurs, then a new restart attempt is
started. Only if the
restart strategy no longer allows further restarts or if the thrown
exception is of type
SuppressRestartsException a job can go from RESTARTING into 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.
---