public class RestartAllFailoverStrategy extends Object implements FailoverStrategy
Modifier and Type | Class and Description |
---|---|
static class |
RestartAllFailoverStrategy.Factory
The factory to instantiate
RestartAllFailoverStrategy . |
Constructor and Description |
---|
RestartAllFailoverStrategy(SchedulingTopology topology) |
Modifier and Type | Method and Description |
---|---|
Set<ExecutionVertexID> |
getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns all vertices on any task failure.
|
public RestartAllFailoverStrategy(SchedulingTopology topology)
public Set<ExecutionVertexID> getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)
getTasksNeedingRestart
in interface FailoverStrategy
executionVertexId
- ID of the failed taskcause
- cause of the failureCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.