Package | Description |
---|---|
org.apache.flink.runtime.executiongraph.failover.flip1 |
Modifier and Type | Method and Description |
---|---|
FailureHandlingResult |
ExecutionFailureHandler.getFailureHandlingResult(ExecutionVertexID failedTask,
Throwable cause)
Return result of failure handling.
|
FailureHandlingResult |
ExecutionFailureHandler.getGlobalFailureHandlingResult(Throwable cause)
Return result of failure handling on a global failure.
|
static FailureHandlingResult |
FailureHandlingResult.restartable(Set<ExecutionVertexID> verticesToRestart,
long restartDelayMS)
Creates a result of a set of tasks to restart to recover from the failure.
|
static FailureHandlingResult |
FailureHandlingResult.unrecoverable(Throwable error)
Creates a result that the failure is not recoverable and no restarting should be conducted.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.