public class NoOpFailoverStrategy extends FailoverStrategy
Modifier and Type | Class and Description |
---|---|
static class |
NoOpFailoverStrategy.Factory |
Constructor and Description |
---|
NoOpFailoverStrategy() |
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.
|
registerMetrics
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.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.