Uses of Class
org.apache.flink.runtime.executiongraph.failover.flip1.FailureHandlingResult

Packages that use FailureHandlingResult

Package	Description
org.apache.flink.runtime.executiongraph.failover.flip1
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.exceptionhistory

Uses of FailureHandlingResult in org.apache.flink.runtime.executiongraph.failover.flip1

Methods in org.apache.flink.runtime.executiongraph.failover.flip1 that return FailureHandlingResult

Modifier and Type	Method	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, CompletableFuture<Map<String,String>> failureLabels, 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, CompletableFuture<Map<String,String>> failureLabels, boolean globalFailure)	Creates a result that the failure is not recoverable and no restarting should be conducted.

Uses of FailureHandlingResult in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler that return FailureHandlingResult

Modifier and Type	Method	Description
protected FailureHandlingResult	DefaultScheduler.recordTaskFailure(Execution failedExecution, Throwable error)

Methods in org.apache.flink.runtime.scheduler with parameters of type FailureHandlingResult

Modifier and Type	Method	Description
protected FailureHandlingResultSnapshot	DefaultScheduler.createFailureHandlingResultSnapshot(FailureHandlingResult failureHandlingResult)

Uses of FailureHandlingResult in org.apache.flink.runtime.scheduler.exceptionhistory

Methods in org.apache.flink.runtime.scheduler.exceptionhistory with parameters of type FailureHandlingResult

Modifier and Type	Method	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.