You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/05/13 14:35:00 UTC

[jira] [Created] (FLINK-17672) OperatorCoordinators receive failure notifications on task failurenstead of restarts

Stephan Ewen created FLINK-17672:
------------------------------------

             Summary:  OperatorCoordinators receive failure notifications on task failurenstead of restarts
                 Key: FLINK-17672
                 URL: https://issues.apache.org/jira/browse/FLINK-17672
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Coordination
            Reporter: Stephan Ewen
            Assignee: Stephan Ewen
             Fix For: 1.11.0


 Currently, the OperatorCoordinators receive failure notifications on task restart. That follows the same approach as the InputSplit assigners from the legacy sources (after which the integration of the Coordinators with the Scheduler was modeled).

However, propagating the failure notifications during the actual failure is more intuitive, and also improve situations where tasks fail but don't get restarted for a while (this can happen for batch tasks when a TM dies and no spare resources are available). In those cases, the coordinator can react much earlier to the failure.




--
This message was sent by Atlassian Jira
(v8.3.4#803005)