flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "shuai.xu (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5866) The implementation of FailoverRegion.
Date Tue, 21 Feb 2017 10:42:44 GMT
shuai.xu created FLINK-5866:

             Summary: The implementation of FailoverRegion.
                 Key: FLINK-5866
                 URL: https://issues.apache.org/jira/browse/FLINK-5866
             Project: Flink
          Issue Type: Sub-task
          Components: JobManager
            Reporter: shuai.xu
            Assignee: shuai.xu

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.

This message was sent by Atlassian JIRA

View raw message