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