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

The implementation of FailoverRegion.

    XMLWordPrintableJSON

    Details

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

      Description

      In flip1, FailoverRegion will manage the failover of a minimal pipelined conncected executions.
      One job graph may has several FailoverRegions and they will be calculated statically after job graph is attached.
      FailoverRegion has serval states, CREATED, CANCELING, CANCELED, RUNNING, it will transforms its state according to the state of the ExectionVertexes it contains and drives the failover during state transformation.
      A FailoverRegion may have preceding and succeeding FailoverRegions. It will wait for its preceding ones and notice its succeeding ones when finishing.

        Attachments

          Activity

            People

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

              Dates

              • Created:
                Updated:
                Resolved: