Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.scheduler.exceptionhistory |
Modifier and Type | Method and Description |
---|---|
List<Execution> |
DefaultCheckpointPlan.getFinishedTasks() |
List<Execution> |
CheckpointPlan.getFinishedTasks()
Returns tasks that have already been finished when taking the checkpoint.
|
List<Execution> |
DefaultCheckpointPlan.getTasksToTrigger() |
List<Execution> |
CheckpointPlan.getTasksToTrigger()
Returns the tasks who need to be sent a message when a checkpoint is started.
|
List<Execution> |
DefaultCheckpointPlan.getTasksToWaitFor() |
List<Execution> |
CheckpointPlan.getTasksToWaitFor()
Returns tasks who need to acknowledge a checkpoint before it succeeds.
|
Modifier and Type | Method and Description |
---|---|
Execution |
ExecutionVertex.getCurrentExecutionAttempt() |
Modifier and Type | Method and Description |
---|---|
Map<ExecutionAttemptID,Execution> |
ExecutionGraph.getRegisteredExecutions() |
Map<ExecutionAttemptID,Execution> |
DefaultExecutionGraph.getRegisteredExecutions() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultExecutionGraph.deregisterExecution(Execution exec) |
void |
InternalExecutionGraphAccessor.deregisterExecution(Execution exec) |
void |
DefaultExecutionGraph.notifyExecutionChange(Execution execution,
ExecutionState previousState,
ExecutionState newExecutionState) |
void |
InternalExecutionGraphAccessor.notifyExecutionChange(Execution execution,
ExecutionState previousState,
ExecutionState newExecutionState) |
void |
DefaultExecutionGraph.registerExecution(Execution exec) |
void |
InternalExecutionGraphAccessor.registerExecution(Execution exec) |
Constructor and Description |
---|
ArchivedExecution(Execution execution) |
IllegalExecutionStateException(Execution execution,
ExecutionState expected,
ExecutionState actual)
Creates a new IllegalExecutionStateException with the error message indicating the expected
and actual state.
|
Modifier and Type | Method and Description |
---|---|
Iterable<Execution> |
FailureHandlingResultSnapshot.getConcurrentlyFailedExecution()
All
Executions that failed and are planned to be restarted as part of this
failure handling. |
Optional<Execution> |
FailureHandlingResultSnapshot.getRootCauseExecution()
Returns the
Execution that handled the root cause for this failure. |
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 . |
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–2023 The Apache Software Foundation. All rights reserved.