public class DefaultScheduler extends SchedulerBase implements SchedulerOperations
executionVertexVersioner
Modifier and Type | Method and Description |
---|---|
void |
allocateSlotsAndDeploy(List<ExecutionVertexDeploymentOption> executionVertexDeploymentOptions)
Allocate slots and deploy the vertex when slots are returned.
|
protected long |
getNumberOfRestarts() |
void |
handleGlobalFailure(Throwable error) |
protected void |
scheduleOrUpdateConsumersInternal(IntermediateResultPartitionID partitionId) |
protected void |
startSchedulingInternal() |
protected void |
updateTaskExecutionStateInternal(ExecutionVertexID executionVertexId,
TaskExecutionState taskExecutionState) |
acknowledgeCheckpoint, cancel, declineCheckpoint, deliverCoordinationRequestToCoordinator, deliverOperatorEventToCoordinator, failJob, getExecutionGraph, getExecutionJobVertex, getExecutionVertex, getExecutionVertexId, getExecutionVertexIdOrThrow, getInputsLocationsRetriever, getJobGraph, getMainThreadExecutor, getResultPartitionAvailabilityChecker, getSchedulingTopology, getTerminationFuture, notifyKvStateRegistered, notifyKvStateUnregistered, prepareExecutionGraphForNgScheduling, registerJobStatusListener, requestJob, requestJobDetails, requestJobStatus, requestKvStateLocation, requestNextInputSplit, requestOperatorBackPressureStats, requestPartitionState, resetForNewExecutions, restoreState, scheduleOrUpdateConsumers, setGlobalFailureCause, setMainThreadExecutor, startCheckpointScheduler, startScheduling, stopCheckpointScheduler, stopWithSavepoint, suspend, transitionExecutionGraphState, transitionToScheduled, triggerSavepoint, updateAccumulators, updateTaskExecutionState
protected long getNumberOfRestarts()
getNumberOfRestarts
in class SchedulerBase
protected void startSchedulingInternal()
startSchedulingInternal
in class SchedulerBase
protected void updateTaskExecutionStateInternal(ExecutionVertexID executionVertexId, TaskExecutionState taskExecutionState)
updateTaskExecutionStateInternal
in class SchedulerBase
public void handleGlobalFailure(Throwable error)
handleGlobalFailure
in interface SchedulerNG
protected void scheduleOrUpdateConsumersInternal(IntermediateResultPartitionID partitionId)
scheduleOrUpdateConsumersInternal
in class SchedulerBase
public void allocateSlotsAndDeploy(List<ExecutionVertexDeploymentOption> executionVertexDeploymentOptions)
SchedulerOperations
allocateSlotsAndDeploy
in interface SchedulerOperations
executionVertexDeploymentOptions
- The deployment options of tasks to be deployedCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.