org.apache.flink.runtime.executiongraph.failover

Class RestartIndividualStrategy

java.lang.Object

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

org.apache.flink.runtime.executiongraph.failover.RestartIndividualStrategy

public class RestartIndividualStrategy
extends FailoverStrategy

Simple failover strategy that restarts each task individually. This strategy is only applicable if the entire job consists unconnected tasks, meaning each task is its own component.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
RestartIndividualStrategy(ExecutionGraph executionGraph) Creates a new failover strategy that recovers from failures by restarting only the failed task of the execution graph.
RestartIndividualStrategy(ExecutionGraph executionGraph, Executor callbackExecutor) Creates a new failover strategy that recovers from failures by restarting only the failed task of the execution graph.

Method Summary

Modifier and Type	Method and Description
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.
void	registerMetrics(MetricGroup metricGroup) Tells the FailoverStrategy to register its metrics.

Methods inherited from class java.lang.Object

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

Constructor Detail

RestartIndividualStrategy

public RestartIndividualStrategy(ExecutionGraph executionGraph)

Creates a new failover strategy that recovers from failures by restarting only the failed task of the execution graph.

The strategy will use the ExecutionGraph's future executor for callbacks.

Parameters:

executionGraph - The execution graph to handle.

RestartIndividualStrategy

public RestartIndividualStrategy(ExecutionGraph executionGraph,
                                 Executor callbackExecutor)

Creates a new failover strategy that recovers from failures by restarting only the failed task of the execution graph.

Parameters:

executionGraph - The execution graph to handle.

callbackExecutor - The executor that executes restart callbacks

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

registerMetrics

public void registerMetrics(MetricGroup metricGroup)

Description copied from class: FailoverStrategy

Tells the FailoverStrategy to register its metrics.

The default implementation does nothing

Overrides:

registerMetrics in class FailoverStrategy

Parameters:

metricGroup - The metric group to register the metrics at