Modifier and Type | Method and Description |
---|---|
ExecutionVertexID |
ExecutionVertex.getID() |
Modifier and Type | Method and Description |
---|---|
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> |
RestartAllFailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns all vertices on any task failure.
|
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)
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> |
FailoverStrategy.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.
|
Modifier and Type | Method and Description |
---|---|
static FailureHandlingResult |
FailureHandlingResult.restartable(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) |
Constructor and Description |
---|
ScheduledUnit(ExecutionVertexID executionVertexId,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
Modifier and Type | Method and Description |
---|---|
ExecutionVertexID |
ExecutionVertexVersion.getExecutionVertexId() |
ExecutionVertexID |
ExecutionVertexSchedulingRequirements.getExecutionVertexId() |
ExecutionVertexID |
ExecutionVertexDeploymentOption.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 |
SchedulerBase.updateTaskExecutionStateInternal(ExecutionVertexID executionVertexId,
TaskExecutionStateTransition taskExecutionState) |
protected void |
DefaultScheduler.updateTaskExecutionStateInternal(ExecutionVertexID executionVertexId,
TaskExecutionStateTransition taskExecutionState) |
ExecutionVertexSchedulingRequirements.Builder |
ExecutionVertexSchedulingRequirements.Builder.withExecutionVertexId(ExecutionVertexID executionVertexId) |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
DefaultSchedulingPipelinedRegion |
DefaultExecutionTopology.getPipelinedRegionOfVertex(ExecutionVertexID vertexId) |
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex |
DefaultExecutionTopology.getVertex(ExecutionVertexID executionVertexId) |
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex |
DefaultSchedulingPipelinedRegion.getVertex(ExecutionVertexID vertexId) |
Modifier and Type | Method and Description |
---|---|
static ExecutionVertexID |
ExecutionVertexID.fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf) |
Modifier and Type | Method and Description |
---|---|
SchedulingExecutionVertex |
SchedulingTopology.getVertex(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
void |
LazyFromSourcesSchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId,
ExecutionState executionState) |
void |
PipelinedRegionSchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId,
ExecutionState executionState) |
void |
EagerSchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId,
ExecutionState executionState) |
void |
SchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId,
ExecutionState executionState)
Called whenever an
Execution changes its state. |
Modifier and Type | Method and Description |
---|---|
void |
LazyFromSourcesSchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart) |
void |
PipelinedRegionSchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart) |
void |
EagerSchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart) |
void |
SchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart)
Called whenever vertices need to be restarted (due to task failure).
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.