Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.failover | |
org.apache.flink.runtime.jobmanager.scheduler |
Modifier and Type | Method and Description |
---|---|
Execution |
ExecutionVertex.getCurrentExecutionAttempt() |
Execution |
ExecutionVertex.resetForNewExecution(long timestamp,
long originatingGlobalModVersion)
Archives the current Execution and creates a new Execution for this vertex.
|
Modifier and Type | Method and Description |
---|---|
Map<ExecutionAttemptID,Execution> |
ExecutionGraph.getRegisteredExecutions() |
CompletableFuture<Execution> |
Execution.registerProducedPartitions(TaskManagerLocation location) |
CompletableFuture<Execution> |
Execution.registerProducedPartitions(TaskManagerLocation location,
boolean sendScheduleOrUpdateConsumersMessage) |
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 |
---|---|
abstract void |
FailoverStrategy.onTaskFailure(Execution taskExecution,
Throwable cause)
Called by the execution graph when a task failure occurs.
|
void |
NoOpFailoverStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
void |
RestartAllStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
Constructor and Description |
---|
ScheduledUnit(Execution task) |
ScheduledUnit(Execution task,
SlotSharingGroupId slotSharingGroupId) |
ScheduledUnit(Execution task,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.