Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.failover | |
org.apache.flink.runtime.jobmanager.scheduler |
Modifier and Type | Field and Description |
---|---|
Execution |
ExecutionAndAllocationFuture.executionAttempt |
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() |
Constructor and Description |
---|
ArchivedExecution(Execution execution) |
ExecutionAndAllocationFuture(Execution executionAttempt,
CompletableFuture<Void> allocationFuture) |
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 |
---|---|
void |
FailoverRegion.onExecutionFail(Execution taskExecution,
Throwable cause) |
void |
RestartAllStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
void |
RestartIndividualStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
void |
AdaptedRestartPipelinedRegionStrategyNG.onTaskFailure(Execution taskExecution,
Throwable cause) |
abstract void |
FailoverStrategy.onTaskFailure(Execution taskExecution,
Throwable cause)
Called by the execution graph when a task failure occurs.
|
void |
RestartPipelinedRegionStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
Execution |
ScheduledUnit.getTaskToExecute() |
Constructor and Description |
---|
ScheduledUnit(Execution task) |
ScheduledUnit(Execution task,
JobVertexID jobVertexId,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
ScheduledUnit(Execution task,
SlotSharingGroupId slotSharingGroupId) |
ScheduledUnit(Execution task,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.