Package | Description |
---|---|
org.apache.flink.runtime.scheduler | |
org.apache.flink.runtime.scheduler.exceptionhistory |
Modifier and Type | Method and Description |
---|---|
Iterable<RootExceptionHistoryEntry> |
ExecutionGraphInfo.getExceptionHistory() |
Constructor and Description |
---|
ExecutionGraphInfo(ArchivedExecutionGraph executionGraph,
Iterable<RootExceptionHistoryEntry> exceptionHistory) |
Modifier and Type | Method and Description |
---|---|
static RootExceptionHistoryEntry |
RootExceptionHistoryEntry.fromFailureHandlingResultSnapshot(FailureHandlingResultSnapshot snapshot)
Creates a
RootExceptionHistoryEntry based on the passed FailureHandlingResultSnapshot . |
static RootExceptionHistoryEntry |
RootExceptionHistoryEntry.fromGlobalFailure(ErrorInfo errorInfo)
Creates a
RootExceptionHistoryEntry based on the passed ErrorInfo . |
static RootExceptionHistoryEntry |
RootExceptionHistoryEntry.fromGlobalFailure(Throwable cause,
long timestamp,
Iterable<Execution> executions)
Creates a
RootExceptionHistoryEntry representing a global failure from the passed
Throwable and timestamp. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.