Package | Description |
---|---|
org.apache.flink.runtime.executiongraph.restart | |
org.apache.flink.runtime.jobmaster |
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 |
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. |
Modifier and Type | Method and Description |
---|---|
RestartStrategyFactory |
JobManagerSharedServices.getRestartStrategyFactory() |
Constructor and Description |
---|
JobManagerSharedServices(ScheduledExecutorService scheduledExecutorService,
LibraryCacheManager libraryCacheManager,
RestartStrategyFactory restartStrategyFactory,
StackTraceSampleCoordinator stackTraceSampleCoordinator,
BackPressureStatsTracker backPressureStatsTracker,
BlobWriter blobWriter) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.