Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.failover |
Class and Description |
---|
FailoverStrategy
A
FailoverStrategy describes how the job computation recovers from task
failures. |
FailoverStrategy.Factory
This factory is a necessary indirection when creating the FailoverStrategy to that
we can have both the FailoverStrategy final in the ExecutionGraph, and the
ExecutionGraph final in the FailOverStrategy.
|
Class and Description |
---|
FailoverRegion
FailoverRegion manages the failover of a minimal pipeline connected sub graph.
|
FailoverStrategy
A
FailoverStrategy describes how the job computation recovers from task
failures. |
FailoverStrategy.Factory
This factory is a necessary indirection when creating the FailoverStrategy to that
we can have both the FailoverStrategy final in the ExecutionGraph, and the
ExecutionGraph final in the FailOverStrategy.
|
RestartIndividualStrategy
Simple failover strategy that restarts each task individually.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.