Package | Description |
---|---|
org.apache.flink.runtime.executiongraph.restart | |
org.apache.flink.runtime.scheduler |
Modifier and Type | Class and Description |
---|---|
static class |
FailureRateRestartStrategy.FailureRateRestartStrategyFactory |
static class |
FixedDelayRestartStrategy.FixedDelayRestartStrategyFactory |
class |
NoOrFixedIfCheckpointingEnabledRestartStrategyFactory
Default restart strategy that resolves either to
NoRestartStrategy or FixedDelayRestartStrategy depending if checkpointing was enabled. |
static class |
NoRestartStrategy.NoRestartStrategyFactory |
static class |
ThrowingRestartStrategy.ThrowingRestartStrategyFactory
Factory for
ThrowingRestartStrategy . |
Modifier and Type | Method and Description |
---|---|
static RestartStrategyFactory |
RestartStrategyFactory.createRestartStrategyFactory(Configuration configuration)
Creates a
RestartStrategy instance from the given Configuration . |
Modifier and Type | Method and Description |
---|---|
static RestartStrategy |
RestartStrategyResolving.resolve(RestartStrategies.RestartStrategyConfiguration clientConfiguration,
RestartStrategyFactory serverStrategyFactory,
boolean isCheckpointingEnabled)
Resolves which
RestartStrategy to use. |
Constructor and Description |
---|
SchedulerBase(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,
ExecutionVertexVersioner executionVertexVersioner,
ExecutionDeploymentTracker executionDeploymentTracker,
boolean legacyScheduling,
long initializationTimestamp) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.