public class AdaptedRestartPipelinedRegionStrategyNG extends FailoverStrategy
Modifier and Type | Class and Description |
---|---|
static class |
AdaptedRestartPipelinedRegionStrategyNG.Factory
Factory that instantiates the AdaptedRestartPipelinedRegionStrategyNG.
|
Constructor and Description |
---|
AdaptedRestartPipelinedRegionStrategyNG(ExecutionGraph executionGraph) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<?> |
cancelTasks(Set<ExecutionVertexID> vertices) |
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.
|
protected void |
restartTasks(Set<ExecutionVertexID> verticesToRestart) |
registerMetrics
public AdaptedRestartPipelinedRegionStrategyNG(ExecutionGraph executionGraph)
public void onTaskFailure(Execution taskExecution, Throwable cause)
FailoverStrategy
onTaskFailure
in class FailoverStrategy
taskExecution
- The execution attempt of the failed task.cause
- The exception that caused the task failure.@VisibleForTesting protected void restartTasks(Set<ExecutionVertexID> verticesToRestart)
@VisibleForTesting protected CompletableFuture<?> cancelTasks(Set<ExecutionVertexID> vertices)
public void notifyNewVertices(List<ExecutionJobVertex> newJobVerticesTopological)
FailoverStrategy
notifyNewVertices
in class FailoverStrategy
newJobVerticesTopological
- The newly added vertices, in topological order.public String getStrategyName()
FailoverStrategy
getStrategyName
in class FailoverStrategy
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.