Package | Description |
---|---|
org.apache.flink.runtime.executiongraph.failover.flip1 | |
org.apache.flink.runtime.scheduler | |
org.apache.flink.runtime.scheduler.exceptionhistory |
Modifier and Type | Method and Description |
---|---|
FailureHandlingResult |
ExecutionFailureHandler.getFailureHandlingResult(Execution failedExecution,
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(Execution failedExecution,
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(Execution failedExecution,
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 |
---|---|
protected FailureHandlingResult |
DefaultScheduler.recordTaskFailure(Execution failedExecution,
Throwable error) |
Modifier and Type | Method and Description |
---|---|
protected FailureHandlingResultSnapshot |
DefaultScheduler.createFailureHandlingResultSnapshot(FailureHandlingResult failureHandlingResult) |
Modifier and Type | Method and Description |
---|---|
static FailureHandlingResultSnapshot |
FailureHandlingResultSnapshot.create(FailureHandlingResult failureHandlingResult,
java.util.function.Function<ExecutionVertexID,Collection<Execution>> currentExecutionsLookup)
Creates a
FailureHandlingResultSnapshot based on the passed FailureHandlingResult and ExecutionVertices . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.