Ufuk Celebi created FLINK-3050:
----------------------------------
Summary: Add custom Exception type to suppress job restarts
Key: FLINK-3050
URL: https://issues.apache.org/jira/browse/FLINK-3050
Project: Flink
Issue Type: Improvement
Components: Distributed Runtime
Affects Versions: 0.10.0
Reporter: Ufuk Celebi
Priority: Minor
Fix For: 1.0.0
In case of failures and configured execution retries, the job will be be
restarted even in cases when the failure is not recoverable.
We can add a custom Exception type like UnrecoverableFailure in order to
suppress restarts in certain cases. The execution graph restart logic can check
the failure type on recovery and skip the restarting.
This Exception can be used both by the system and the user.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
