Modifier and Type | Method and Description |
---|---|
ExecutionVertexID |
ExecutionAttemptID.getExecutionVertexId() |
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) |
Constructor and Description |
---|
ExecutionAttemptID(ExecutionGraphID executionGraphId,
ExecutionVertexID executionVertexId,
int attemptNumber) |
Modifier and Type | Method and Description |
---|---|
Set<ExecutionVertexID> |
RestartAllFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns all vertices on any task 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> |
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.
|
Set<ExecutionVertexID> |
RestartAllFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns all vertices on any task 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> |
FailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
Modifier and Type | Method and Description |
---|---|
static Set<Set<SchedulingExecutionVertex>> |
SchedulingPipelinedRegionComputeUtil.computePipelinedRegions(Iterable<? extends SchedulingExecutionVertex> topologicallySortedVertices,
java.util.function.Function<ExecutionVertexID,? extends SchedulingExecutionVertex> executionVertexRetriever,
java.util.function.Function<IntermediateResultPartitionID,? extends SchedulingResultPartition> resultPartitionRetriever) |
static FailureHandlingResult |
FailureHandlingResult.restartable(Execution failedExecution,
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 |
---|---|
boolean |
RegionPartitionGroupReleaseStrategy.isRegionOfVertexFinished(ExecutionVertexID executionVertexId) |
List<ConsumedPartitionGroup> |
RegionPartitionGroupReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
List<ConsumedPartitionGroup> |
NotReleasingPartitionGroupReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
List<ConsumedPartitionGroup> |
PartitionGroupReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex)
Calling this method informs the strategy that a vertex finished.
|
void |
RegionPartitionGroupReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexId) |
void |
NotReleasingPartitionGroupReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexID) |
void |
PartitionGroupReleaseStrategy.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.
|
Modifier and Type | Method and Description |
---|---|
void |
RegionPartitionGroupReleaseStrategy.notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology,
List<ExecutionVertexID> newExecutionVertices) |
Modifier and Type | Method and Description |
---|---|
ExecutionVertexID |
ExecutionVertexVersion.getExecutionVertexId() |
Modifier and Type | Method and Description |
---|---|
Collection<Collection<ExecutionVertexID>> |
ExecutionGraphToInputsLocationsRetrieverAdapter.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId) |
Collection<Collection<ExecutionVertexID>> |
InputsLocationsRetriever.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId)
Get the producers of the result partitions consumed by an execution.
|
Map<ExecutionVertexID,ExecutionVertexVersion> |
ExecutionVertexVersioner.getExecutionVertexVersions(Collection<ExecutionVertexID> executionVertexIds) |
Set<ExecutionVertexID> |
ExecutionVertexVersioner.getUnmodifiedExecutionVertices(Set<ExecutionVertexVersion> executionVertexVersions) |
Map<ExecutionVertexID,ExecutionVertexVersion> |
ExecutionVertexVersioner.recordVertexModifications(Collection<ExecutionVertexID> vertices) |
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultScheduler.cancelAllPendingSlotRequestsForVertex(ExecutionVertexID executionVertexId) |
Collection<Collection<ExecutionVertexID>> |
ExecutionGraphToInputsLocationsRetrieverAdapter.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId) |
Collection<Collection<ExecutionVertexID>> |
InputsLocationsRetriever.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId)
Get the producers of the result partitions consumed by an execution.
|
ExecutionVertex |
SchedulerBase.getExecutionVertex(ExecutionVertexID executionVertexId) |
CompletableFuture<Collection<TaskManagerLocation>> |
PreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore)
Returns preferred locations of an execution vertex.
|
Collection<TaskManagerLocation> |
SyncPreferredLocationsRetriever.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>> |
ExecutionGraphToInputsLocationsRetrieverAdapter.getTaskManagerLocation(ExecutionVertexID executionVertexId) |
Optional<CompletableFuture<TaskManagerLocation>> |
InputsLocationsRetriever.getTaskManagerLocation(ExecutionVertexID executionVertexId)
Get the task manager location future for an execution.
|
ExecutionVertexVersion |
ExecutionVertexVersioner.recordModification(ExecutionVertexID executionVertexId) |
protected void |
SchedulerBase.resetForNewExecution(ExecutionVertexID executionVertexId) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultExecutionDeployer.allocateSlotsAndDeploy(List<Execution> executionsToDeploy,
Map<ExecutionVertexID,ExecutionVertexVersion> requiredVersionByVertex) |
void |
ExecutionDeployer.allocateSlotsAndDeploy(List<Execution> executionsToDeploy,
Map<ExecutionVertexID,ExecutionVertexVersion> requiredVersionByVertex)
Allocate slots and deploy executions.
|
void |
SchedulerOperations.allocateSlotsAndDeploy(List<ExecutionVertexID> verticesToDeploy)
Allocate slots and deploy the vertex when slots are returned.
|
void |
DefaultScheduler.allocateSlotsAndDeploy(List<ExecutionVertexID> verticesToDeploy) |
DefaultExecutionDeployer |
DefaultExecutionDeployer.Factory.createInstance(org.slf4j.Logger log,
ExecutionSlotAllocator executionSlotAllocator,
ExecutionOperations executionOperations,
ExecutionVertexVersioner executionVertexVersioner,
Time partitionRegistrationTimeout,
java.util.function.BiConsumer<ExecutionVertexID,AllocationID> allocationReservationFunc,
ComponentMainThreadExecutor mainThreadExecutor) |
ExecutionDeployer |
ExecutionDeployer.Factory.createInstance(org.slf4j.Logger log,
ExecutionSlotAllocator executionSlotAllocator,
ExecutionOperations executionOperations,
ExecutionVertexVersioner executionVertexVersioner,
Time partitionRegistrationTimeout,
java.util.function.BiConsumer<ExecutionVertexID,AllocationID> allocationReservationFunc,
ComponentMainThreadExecutor mainThreadExecutor)
Instantiate an
ExecutionDeployer with the given params. |
Map<ExecutionVertexID,ExecutionVertexVersion> |
ExecutionVertexVersioner.getExecutionVertexVersions(Collection<ExecutionVertexID> executionVertexIds) |
CompletableFuture<Collection<TaskManagerLocation>> |
PreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore)
Returns preferred locations of an execution vertex.
|
Collection<TaskManagerLocation> |
SyncPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore)
Returns preferred locations of an execution vertex.
|
CompletableFuture<Collection<TaskManagerLocation>> |
DefaultPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore) |
void |
SchedulingTopologyListener.notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology,
List<ExecutionVertexID> newExecutionVertices)
Notifies that the scheduling topology is just updated.
|
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) |
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 |
---|---|
SpeculativeExecutionVertex |
SpeculativeScheduler.getExecutionVertex(ExecutionVertexID executionVertexId) |
protected void |
SpeculativeScheduler.resetForNewExecution(ExecutionVertexID executionVertexId) |
Modifier and Type | Method and Description |
---|---|
void |
SpeculativeScheduler.notifySlowTasks(Map<ExecutionVertexID,Collection<ExecutionAttemptID>> slowTasks) |
Modifier and Type | Method and Description |
---|---|
static FailureHandlingResultSnapshot |
FailureHandlingResultSnapshot.create(FailureHandlingResult failureHandlingResult,
java.util.function.Function<ExecutionVertexID,Collection<Execution>> currentExecutionsLookup)
Creates a
FailureHandlingResultSnapshot based on the passed FailureHandlingResult and ExecutionVertices . |
Modifier and Type | Method and Description |
---|---|
void |
SlowTaskDetectorListener.notifySlowTasks(Map<ExecutionVertexID,Collection<ExecutionAttemptID>> slowTasks)
Notify detected slow tasks.
|
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 |
VertexwiseSchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId,
ExecutionState executionState) |
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 |
VertexwiseSchedulingStrategy.notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology,
List<ExecutionVertexID> newExecutionVertices) |
void |
VertexwiseSchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart) |
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.