Package | Description |
---|---|
org.apache.flink.runtime.scheduler.exceptionhistory |
Modifier and Type | Class and Description |
---|---|
class |
RootExceptionHistoryEntry
RootExceptionHistoryEntry extending ExceptionHistoryEntry by providing a list of
ExceptionHistoryEntry instances to store concurrently caught failures. |
Modifier and Type | Method and Description |
---|---|
static ExceptionHistoryEntry |
ExceptionHistoryEntry.create(AccessExecution failedExecution,
String taskName)
Creates an
ExceptionHistoryEntry based on the provided Execution . |
Modifier and Type | Method and Description |
---|---|
Iterable<ExceptionHistoryEntry> |
RootExceptionHistoryEntry.getConcurrentExceptions() |
Constructor and Description |
---|
RootExceptionHistoryEntry(Throwable cause,
long timestamp,
String failingTaskName,
TaskManagerLocation taskManagerLocation,
Set<ExceptionHistoryEntry> concurrentExceptions)
Instantiates a
RootExceptionHistoryEntry . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.