flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ufuk Celebi (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3050) Add custom Exception type to suppress job restarts
Date Thu, 19 Nov 2015 13:55:10 GMT
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

View raw message