Modifier and Type | Method and Description |
---|---|
ExecutionVertexID |
ExecutionVertex.getID() |
Modifier and Type | Method and Description |
---|---|
void |
EdgeManager.connectVertexWithConsumedPartitionGroup(ExecutionVertexID executionVertexId,
ConsumedPartitionGroup consumedPartitionGroup) |
List<ConsumedPartitionGroup> |
EdgeManager.getConsumedPartitionGroupsForVertex(ExecutionVertexID executionVertexId) |
ExecutionVertex |
DefaultExecutionGraph.getExecutionVertexOrThrow(ExecutionVertexID id) |
ExecutionVertex |
InternalExecutionGraphAccessor.getExecutionVertexOrThrow(ExecutionVertexID id) |
Modifier and Type | Method and Description |
---|---|
Optional<ExecutionVertexID> |
FailureHandlingResult.getExecutionVertexIdOfFailedTask()
Returns an
Optional with the ExecutionVertexID of the task causing this
failure or an empty Optional if it's a global failure. |
Set<ExecutionVertexID> |
RestartPipelinedRegionFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
Set<ExecutionVertexID> |
RestartAllFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns all vertices on any task failure.
|
Set<ExecutionVertexID> |
FailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
Set<ExecutionVertexID> |
FailureHandlingResult.getVerticesToRestart()
Returns the tasks to restart.
|
Modifier and Type | Method and Description |
---|---|
SchedulingPipelinedRegion |
RestartPipelinedRegionFailoverStrategy.getFailoverRegion(ExecutionVertexID vertexID)
Returns the failover region that contains the given execution vertex.
|
FailureHandlingResult |
ExecutionFailureHandler.getFailureHandlingResult(ExecutionVertexID failedTask,
Throwable cause,
long timestamp)
Return result of failure handling.
|
Set<ExecutionVertexID> |
RestartPipelinedRegionFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
Set<ExecutionVertexID> |
RestartAllFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns all vertices on any task failure.
|
Set<ExecutionVertexID> |
FailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
static FailureHandlingResult |
FailureHandlingResult.restartable(ExecutionVertexID failingExecutionVertexId,
Throwable cause,
long timestamp,
Set<ExecutionVertexID> verticesToRestart,
long restartDelayMS,
boolean globalFailure)
Creates a result of a set of tasks to restart to recover from the failure.
|
static FailureHandlingResult |
FailureHandlingResult.unrecoverable(ExecutionVertexID failingExecutionVertexId,
Throwable error,
long timestamp,
boolean globalFailure)
Creates a result that the failure is not recoverable and no restarting should be conducted.
|
Modifier and Type | Method and Description |
---|---|
static FailureHandlingResult |
FailureHandlingResult.restartable(ExecutionVertexID failingExecutionVertexId,
Throwable cause,
long timestamp,
Set<ExecutionVertexID> verticesToRestart,
long restartDelayMS,
boolean globalFailure)
Creates a result of a set of tasks to restart to recover from the failure.
|
Modifier and Type | Method and Description |
---|---|
List<IntermediateResultPartitionID> |
RegionPartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
List<IntermediateResultPartitionID> |
PartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex)
Calling this method informs the strategy that a vertex finished.
|
List<IntermediateResultPartitionID> |
NotReleasingPartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
void |
RegionPartitionReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexId) |
void |
PartitionReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexID)
Calling this method informs the strategy that a vertex is no longer in finished state, e.g.,
when a vertex is re-executed.
|
void |
NotReleasingPartitionReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexID) |
Modifier and Type | Method and Description |
---|---|
ExecutionVertexID |
ExecutionVertexDeploymentOption.getExecutionVertexId() |
ExecutionVertexID |
ExecutionVertexVersion.getExecutionVertexId() |
protected ExecutionVertexID |
SchedulerBase.getExecutionVertexIdOrThrow(ExecutionAttemptID executionAttemptId) |
Modifier and Type | Method and Description |
---|---|
Collection<Collection<ExecutionVertexID>> |
InputsLocationsRetriever.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId)
Get the producers of the result partitions consumed by an execution.
|
Collection<Collection<ExecutionVertexID>> |
ExecutionGraphToInputsLocationsRetrieverAdapter.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId) |
protected Optional<ExecutionVertexID> |
SchedulerBase.getExecutionVertexId(ExecutionAttemptID executionAttemptId) |
Set<ExecutionVertexID> |
ExecutionVertexVersioner.getUnmodifiedExecutionVertices(Set<ExecutionVertexVersion> executionVertexVersions) |
Map<ExecutionVertexID,ExecutionVertexVersion> |
ExecutionVertexVersioner.recordVertexModifications(Collection<ExecutionVertexID> vertices) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionSlotAllocator.cancel(ExecutionVertexID executionVertexId)
Cancel an ongoing slot request.
|
Collection<Collection<ExecutionVertexID>> |
InputsLocationsRetriever.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId)
Get the producers of the result partitions consumed by an execution.
|
Collection<Collection<ExecutionVertexID>> |
ExecutionGraphToInputsLocationsRetrieverAdapter.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId) |
ExecutionVertex |
SchedulerBase.getExecutionVertex(ExecutionVertexID executionVertexId) |
Collection<TaskManagerLocation> |
SyncPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore)
Returns preferred locations of an execution vertex.
|
CompletableFuture<Collection<TaskManagerLocation>> |
PreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore)
Returns preferred locations of an execution vertex.
|
CompletableFuture<Collection<TaskManagerLocation>> |
DefaultPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore) |
Optional<TaskManagerLocation> |
StateLocationRetriever.getStateLocation(ExecutionVertexID executionVertexId)
Returns state location of an execution vertex.
|
Optional<CompletableFuture<TaskManagerLocation>> |
InputsLocationsRetriever.getTaskManagerLocation(ExecutionVertexID executionVertexId)
Get the task manager location future for an execution.
|
Optional<CompletableFuture<TaskManagerLocation>> |
ExecutionGraphToInputsLocationsRetrieverAdapter.getTaskManagerLocation(ExecutionVertexID executionVertexId) |
ExecutionVertexVersion |
ExecutionVertexVersioner.recordModification(ExecutionVertexID executionVertexId) |
protected void |
DefaultScheduler.updateTaskExecutionStateInternal(ExecutionVertexID executionVertexId,
TaskExecutionStateTransition taskExecutionState) |
protected void |
SchedulerBase.updateTaskExecutionStateInternal(ExecutionVertexID executionVertexId,
TaskExecutionStateTransition taskExecutionState) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.flink.runtime.scheduler.SlotExecutionVertexAssignment> |
ExecutionSlotAllocator.allocateSlotsFor(List<ExecutionVertexID> executionVertexIds)
Allocate slots for the given executions.
|
Collection<TaskManagerLocation> |
SyncPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore)
Returns preferred locations of an execution vertex.
|
CompletableFuture<Collection<TaskManagerLocation>> |
PreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore)
Returns preferred locations of an execution vertex.
|
CompletableFuture<Collection<TaskManagerLocation>> |
DefaultPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore) |
Map<ExecutionVertexID,ExecutionVertexVersion> |
ExecutionVertexVersioner.recordVertexModifications(Collection<ExecutionVertexID> vertices) |
protected void |
SchedulerBase.resetForNewExecutions(Collection<ExecutionVertexID> vertices) |
protected void |
SchedulerBase.restoreState(Set<ExecutionVertexID> vertices,
boolean isGlobalRecovery) |
protected void |
SchedulerBase.transitionToScheduled(List<ExecutionVertexID> verticesToDeploy) |
Constructor and Description |
---|
ExecutionVertexDeploymentOption(ExecutionVertexID executionVertexId,
DeploymentOption deploymentOption) |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultSchedulingPipelinedRegion.contains(ExecutionVertexID vertexId) |
DefaultSchedulingPipelinedRegion |
DefaultExecutionTopology.getPipelinedRegionOfVertex(ExecutionVertexID vertexId) |
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex |
DefaultSchedulingPipelinedRegion.getVertex(ExecutionVertexID vertexId) |
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex |
DefaultExecutionTopology.getVertex(ExecutionVertexID executionVertexId) |
Modifier and Type | Method and Description |
---|---|
LogicalSlot |
ReservedSlots.getSlotFor(ExecutionVertexID executionVertexId) |
Modifier and Type | Method and Description |
---|---|
static ReservedSlots |
ReservedSlots.create(Map<ExecutionVertexID,LogicalSlot> assignedSlots) |
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 . |
Modifier and Type | Method and Description |
---|---|
static ExecutionVertexID |
ExecutionVertexID.fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf) |
ExecutionVertexID |
ConsumerVertexGroup.getFirst() |
Modifier and Type | Method and Description |
---|---|
Iterator<ExecutionVertexID> |
ConsumerVertexGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
static ConsumerVertexGroup |
ConsumerVertexGroup.fromSingleVertex(ExecutionVertexID vertex) |
SchedulingExecutionVertex |
SchedulingTopology.getVertex(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
void |
SchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId,
ExecutionState executionState)
Called whenever an
Execution changes its state. |
void |
PipelinedRegionSchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId,
ExecutionState executionState) |
Modifier and Type | Method and Description |
---|---|
static ConsumerVertexGroup |
ConsumerVertexGroup.fromMultipleVertices(List<ExecutionVertexID> vertices) |
void |
SchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart)
Called whenever vertices need to be restarted (due to task failure).
|
void |
PipelinedRegionSchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.