org.apache.flink.runtime.executiongraph.failover

Class RestartPipelinedRegionStrategy

java.lang.Object

org.apache.flink.runtime.executiongraph.failover.FailoverStrategy

org.apache.flink.runtime.executiongraph.failover.RestartPipelinedRegionStrategy

public class RestartPipelinedRegionStrategy
extends FailoverStrategy

A failover strategy that restarts regions of the ExecutionGraph. A region is defined by this strategy as the weakly connected component of tasks that communicate via pipelined data exchange.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RestartPipelinedRegionStrategy.Factory Factory that instantiates the RestartPipelinedRegionStrategy.

Constructor Summary

Constructors

Constructor and Description
RestartPipelinedRegionStrategy(ExecutionGraph executionGraph) Creates a new failover strategy to restart pipelined regions that works on the given execution graph and uses the execution graph's future executor to call restart actions.
RestartPipelinedRegionStrategy(ExecutionGraph executionGraph, Executor executor) Creates a new failover strategy to restart pipelined regions that works on the given execution graph and uses the given executor to call restart actions.

Method Summary

Modifier and Type	Method and Description
FailoverRegion	getFailoverRegion(ExecutionVertex ev) Finds the failover region that contains the given execution vertex.
String	getStrategyName() Gets the name of the failover strategy, for logging purposes.
void	notifyNewVertices(List<ExecutionJobVertex> newJobVerticesTopological) Called whenever new vertices are added to the ExecutionGraph.
void	onTaskFailure(Execution taskExecution, Throwable cause) Called by the execution graph when a task failure occurs.

Methods inherited from class org.apache.flink.runtime.executiongraph.failover.FailoverStrategy

registerMetrics

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RestartPipelinedRegionStrategy

public RestartPipelinedRegionStrategy(ExecutionGraph executionGraph)

Creates a new failover strategy to restart pipelined regions that works on the given execution graph and uses the execution graph's future executor to call restart actions.

Parameters:

executionGraph - The execution graph on which this FailoverStrategy will work

RestartPipelinedRegionStrategy

public RestartPipelinedRegionStrategy(ExecutionGraph executionGraph,
                                      Executor executor)

Creates a new failover strategy to restart pipelined regions that works on the given execution graph and uses the given executor to call restart actions.

Parameters:

executionGraph - The execution graph on which this FailoverStrategy will work

executor - The executor used for future actions

Method Detail

onTaskFailure

public void onTaskFailure(Execution taskExecution,
                          Throwable cause)

Description copied from class: FailoverStrategy

Called by the execution graph when a task failure occurs.

Specified by:

onTaskFailure in class FailoverStrategy

Parameters:

taskExecution - The execution attempt of the failed task.

cause - The exception that caused the task failure.

notifyNewVertices

public void notifyNewVertices(List<ExecutionJobVertex> newJobVerticesTopological)

Description copied from class: FailoverStrategy

Called whenever new vertices are added to the ExecutionGraph.

Specified by:

notifyNewVertices in class FailoverStrategy

Parameters:

newJobVerticesTopological - The newly added vertices, in topological order.

getStrategyName

public String getStrategyName()

Description copied from class: FailoverStrategy

Gets the name of the failover strategy, for logging purposes.

Specified by:

getStrategyName in class FailoverStrategy

getFailoverRegion

@VisibleForTesting
public FailoverRegion getFailoverRegion(ExecutionVertex ev)

Finds the failover region that contains the given execution vertex.