Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.scheduler.exceptionhistory |
Modifier and Type | Method and Description |
---|---|
static ErrorInfo |
ErrorInfo.createErrorInfoWithNullableCause(Throwable exception,
long timestamp)
Instantiates an
ErrorInfo to cover inconsistent behavior due to FLINK-21376. |
ErrorInfo |
DefaultExecutionGraph.getFailureInfo() |
ErrorInfo |
AccessExecutionGraph.getFailureInfo()
Returns the exception that caused the job to fail.
|
ErrorInfo |
ArchivedExecutionGraph.getFailureInfo() |
Modifier and Type | Method and Description |
---|---|
Optional<ErrorInfo> |
ExecutionVertex.getFailureInfo() |
Optional<ErrorInfo> |
AccessExecution.getFailureInfo()
Returns the exception that caused the job to fail.
|
Optional<ErrorInfo> |
ArchivedExecutionVertex.getFailureInfo() |
Optional<ErrorInfo> |
Execution.getFailureInfo() |
Optional<ErrorInfo> |
ArchivedExecution.getFailureInfo() |
Optional<ErrorInfo> |
AccessExecutionVertex.getFailureInfo()
Returns the exception that caused the job to fail.
|
Constructor and Description |
---|
ArchivedExecution(StringifiedAccumulatorResult[] userAccumulators,
IOMetrics ioMetrics,
ExecutionAttemptID attemptId,
ExecutionState state,
ErrorInfo failureCause,
TaskManagerLocation assignedResourceLocation,
AllocationID assignedAllocationID,
long[] stateTimestamps,
long[] stateEndTimestamps) |
ArchivedExecutionGraph(JobID jobID,
String jobName,
Map<JobVertexID,ArchivedExecutionJobVertex> tasks,
List<ArchivedExecutionJobVertex> verticesInCreationOrder,
long[] stateTimestamps,
JobStatus state,
ErrorInfo failureCause,
String jsonPlan,
StringifiedAccumulatorResult[] archivedUserAccumulators,
Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators,
ArchivedExecutionConfig executionConfig,
boolean isStoppable,
CheckpointCoordinatorConfiguration jobCheckpointingConfiguration,
CheckpointStatsSnapshot checkpointStatsSnapshot,
String stateBackendName,
String checkpointStorageName,
TernaryBoolean stateChangelogEnabled,
String changelogStorageName) |
Modifier and Type | Class and Description |
---|---|
class |
ExceptionHistoryEntry
ExceptionHistoryEntry collects information about a single failure that triggered the
scheduler's failure handling. |
class |
RootExceptionHistoryEntry
RootExceptionHistoryEntry extending ExceptionHistoryEntry by providing a list of
ExceptionHistoryEntry instances to store concurrently caught failures. |
Modifier and Type | Method and Description |
---|---|
static RootExceptionHistoryEntry |
RootExceptionHistoryEntry.fromGlobalFailure(ErrorInfo errorInfo)
Creates a
RootExceptionHistoryEntry based on the passed ErrorInfo . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.