public class ExecutionFailureHandler extends Object
FailureHandlingResult
which contains tasks
to restart to recover from failures.Constructor and Description |
---|
ExecutionFailureHandler(FailoverStrategy failoverStrategy,
RestartBackoffTimeStrategy restartBackoffTimeStrategy)
Creates the handler to deal with task failures.
|
Modifier and Type | Method and Description |
---|---|
FailureHandlingResult |
getFailureHandlingResult(ExecutionVertexID failedTask,
Throwable cause)
Return result of failure handling.
|
public ExecutionFailureHandler(FailoverStrategy failoverStrategy, RestartBackoffTimeStrategy restartBackoffTimeStrategy)
failoverStrategy
- helps to decide tasks to restart on task failuresrestartBackoffTimeStrategy
- helps to decide whether to restart failed tasks and the restarting delaypublic FailureHandlingResult getFailureHandlingResult(ExecutionVertexID failedTask, Throwable cause)
failedTask
- is the ID of the failed task vertexcause
- of the task failureCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.