Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-4256 Fine-grained recovery
  3. FLINK-5869

ExecutionGraph use FailoverCoordinator to manage the failover of execution vertexes

    Details

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.3.0
    • Component/s: JobManager
    • Labels:
      None

      Description

      Execution graph doesn't manage the failover of executions. It only care for the state of the whole job, which is CREATED, RUNNING, FAILED, FINISHED, or SUSPEND.
      For execution failure, it will notice the FailoverCoordinator to do failover.
      It only record the finished job vertex and changes to FINISHED after all vertexes finished.
      It will change to final fail if restart strategy fail or meet unrecoverable exceptions.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                tiemsn shuai.xu
                Reporter:
                tiemsn shuai.xu
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: