Package | Description |
---|---|
org.apache.flink.runtime.scheduler | |
org.apache.flink.runtime.scheduler.exceptionhistory |
Modifier and Type | Method and Description |
---|---|
protected void |
SchedulerBase.archiveFromFailureHandlingResult(FailureHandlingResultSnapshot failureHandlingResult) |
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 . |
Modifier and Type | Method and Description |
---|---|
static RootExceptionHistoryEntry |
RootExceptionHistoryEntry.fromFailureHandlingResultSnapshot(FailureHandlingResultSnapshot snapshot)
Creates a
RootExceptionHistoryEntry based on the passed FailureHandlingResultSnapshot . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.