public class LegacyScheduler extends SchedulerBase
ExecutionGraph
.ExecutionGraph.scheduleForExecution()
executionVertexVersioner
Constructor and Description |
---|
LegacyScheduler(org.slf4j.Logger log,
JobGraph jobGraph,
BackPressureStatsTracker backPressureStatsTracker,
Executor ioExecutor,
Configuration jobMasterConfiguration,
SlotProvider slotProvider,
ScheduledExecutorService futureExecutor,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Time rpcTimeout,
RestartStrategyFactory restartStrategyFactory,
BlobWriter blobWriter,
JobManagerJobMetricGroup jobManagerJobMetricGroup,
Time slotRequestTimeout,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker) |
Modifier and Type | Method and Description |
---|---|
protected long |
getNumberOfRestarts() |
void |
handleGlobalFailure(Throwable cause) |
protected void |
startSchedulingInternal() |
acknowledgeCheckpoint, cancel, declineCheckpoint, failJob, getExecutionGraph, getExecutionVertex, getExecutionVertexId, getExecutionVertexIdOrThrow, getFailoverTopology, getInputsLocationsRetriever, getJobGraph, getMainThreadExecutor, getResultPartitionAvailabilityChecker, getSchedulingTopology, getTerminationFuture, notifyKvStateRegistered, notifyKvStateUnregistered, prepareExecutionGraphForNgScheduling, registerJobStatusListener, requestJob, requestJobDetails, requestJobStatus, requestKvStateLocation, requestNextInputSplit, requestOperatorBackPressureStats, requestPartitionState, resetForNewExecutions, restoreState, scheduleOrUpdateConsumers, scheduleOrUpdateConsumersInternal, setGlobalFailureCause, setMainThreadExecutor, startScheduling, stopWithSavepoint, suspend, transitionExecutionGraphState, transitionToScheduled, triggerSavepoint, updateAccumulators, updateTaskExecutionState, updateTaskExecutionStateInternal
public LegacyScheduler(org.slf4j.Logger log, JobGraph jobGraph, BackPressureStatsTracker backPressureStatsTracker, Executor ioExecutor, Configuration jobMasterConfiguration, SlotProvider slotProvider, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, RestartStrategyFactory restartStrategyFactory, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker) throws Exception
Exception
protected long getNumberOfRestarts()
getNumberOfRestarts
in class SchedulerBase
protected void startSchedulingInternal()
startSchedulingInternal
in class SchedulerBase
public void handleGlobalFailure(Throwable cause)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.