Package | Description |
---|---|
org.apache.flink.runtime.executiongraph.failover.flip1 | |
org.apache.flink.runtime.scheduler.exceptionhistory |
Modifier and Type | Method and Description |
---|---|
FailureHandlingResult |
ExecutionFailureHandler.getFailureHandlingResult(ExecutionVertexID failedTask,
Throwable cause,
long timestamp)
Return result of failure handling.
|
FailureHandlingResult |
ExecutionFailureHandler.getGlobalFailureHandlingResult(Throwable cause,
long timestamp)
Return result of failure handling on a global failure.
|
static FailureHandlingResult |
FailureHandlingResult.restartable(ExecutionVertexID failingExecutionVertexId,
Throwable cause,
long timestamp,
Set<ExecutionVertexID> verticesToRestart,
long restartDelayMS,
boolean globalFailure)
Creates a result of a set of tasks to restart to recover from the failure.
|
static FailureHandlingResult |
FailureHandlingResult.unrecoverable(ExecutionVertexID failingExecutionVertexId,
Throwable error,
long timestamp,
boolean globalFailure)
Creates a result that the failure is not recoverable and no restarting should be conducted.
|
Modifier and Type | Method and Description |
---|---|
static FailureHandlingResultSnapshot |
FailureHandlingResultSnapshot.create(FailureHandlingResult failureHandlingResult,
java.util.function.Function<ExecutionVertexID,Execution> latestExecutionLookup)
Creates a
FailureHandlingResultSnapshot based on the passed FailureHandlingResult and ExecutionVertices . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.