public class DefaultScheduler extends SchedulerBase implements SchedulerOperations
executionVertexVersioner, inputsLocationsRetriever, stateLocationRetriever
Modifier and Type | Method and Description |
---|---|
void |
allocateSlotsAndDeploy(List<ExecutionVertexDeploymentOption> executionVertexDeploymentOptions)
Allocate slots and deploy the vertex when slots are returned.
|
protected void |
cancelAllPendingSlotRequestsInternal() |
protected long |
getNumberOfRestarts() |
void |
handleGlobalFailure(Throwable error) |
protected void |
notifyPartitionDataAvailableInternal(IntermediateResultPartitionID partitionId) |
protected void |
startSchedulingInternal() |
protected void |
updateTaskExecutionStateInternal(ExecutionVertexID executionVertexId,
TaskExecutionStateTransition taskExecutionState) |
acknowledgeCheckpoint, archiveFromFailureHandlingResult, archiveGlobalFailure, cancel, closeAsync, computeVertexParallelismStore, computeVertexParallelismStore, computeVertexParallelismStore, declineCheckpoint, deliverCoordinationRequestToCoordinator, deliverOperatorEventToCoordinator, failJob, getDefaultMaxParallelism, getExecutionGraph, getExecutionJobVertex, getExecutionVertex, getExecutionVertexId, getExecutionVertexIdOrThrow, getJobGraph, getJobTerminationFuture, getMainThreadExecutor, getResultPartitionAvailabilityChecker, getSchedulingTopology, notifyKvStateRegistered, notifyKvStateUnregistered, notifyPartitionDataAvailable, reportCheckpointMetrics, requestJob, requestJobDetails, requestJobStatus, requestKvStateLocation, requestNextInputSplit, requestPartitionState, resetForNewExecutions, restoreState, setGlobalFailureCause, startCheckpointScheduler, startScheduling, stopCheckpointScheduler, stopWithSavepoint, transitionExecutionGraphState, transitionToRunning, transitionToScheduled, triggerSavepoint, updateAccumulators, updateTaskExecutionState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
updateTaskExecutionState
close
protected long getNumberOfRestarts()
getNumberOfRestarts
in class SchedulerBase
protected void cancelAllPendingSlotRequestsInternal()
cancelAllPendingSlotRequestsInternal
in class SchedulerBase
protected void startSchedulingInternal()
startSchedulingInternal
in class SchedulerBase
protected void updateTaskExecutionStateInternal(ExecutionVertexID executionVertexId, TaskExecutionStateTransition taskExecutionState)
updateTaskExecutionStateInternal
in class SchedulerBase
public void handleGlobalFailure(Throwable error)
handleGlobalFailure
in interface SchedulerNG
protected void notifyPartitionDataAvailableInternal(IntermediateResultPartitionID partitionId)
notifyPartitionDataAvailableInternal
in class SchedulerBase
public void allocateSlotsAndDeploy(List<ExecutionVertexDeploymentOption> executionVertexDeploymentOptions)
SchedulerOperations
allocateSlotsAndDeploy
in interface SchedulerOperations
executionVertexDeploymentOptions
- The deployment options of tasks to be deployedCopyright © 2014–2022 The Apache Software Foundation. All rights reserved.