RestartStrategies
class is marked as deprecated because starting from
Flink 1.19, all complex Java objects related to configuration should be replaced by
ConfigOption. In a future major version of Flink, this class will be removed entirely. It is
recommended to switch to using the ConfigOptions provided by RestartStrategyOptions
for configuring restart strategies
like the following code snippet:
Configuration config = new Configuration();
config.set(RestartStrategyOptions.RESTART_STRATEGY, "fixed-delay");
config.set(RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS, 3);
config.set(RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_DELAY, Duration.ofMinutes(1));
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);
For more details on using ConfigOption for restart strategies, please refer to the Flink
documentation: restart-strategies@Deprecated @PublicEvolving public class RestartStrategies extends Object
The RestartStrategyConfigurations are used to decouple the core module from the runtime module.
Modifier and Type | Class and Description |
---|---|
static class |
RestartStrategies.ExponentialDelayRestartStrategyConfiguration
Deprecated.
Configuration representing an exponential delay restart strategy.
|
static class |
RestartStrategies.FailureRateRestartStrategyConfiguration
Deprecated.
Configuration representing a failure rate restart strategy.
|
static class |
RestartStrategies.FallbackRestartStrategyConfiguration
Deprecated.
Restart strategy configuration that could be used by jobs to use cluster level restart
strategy.
|
static class |
RestartStrategies.FixedDelayRestartStrategyConfiguration
Deprecated.
Configuration representing a fixed delay restart strategy.
|
static class |
RestartStrategies.NoRestartStrategyConfiguration
Deprecated.
Configuration representing no restart strategy.
|
static class |
RestartStrategies.RestartStrategyConfiguration
Deprecated.
Abstract configuration for restart strategies.
|
Constructor and Description |
---|
RestartStrategies()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static RestartStrategies.ExponentialDelayRestartStrategyConfiguration |
exponentialDelayRestart(java.time.Duration initialBackoff,
java.time.Duration maxBackoff,
double backoffMultiplier,
java.time.Duration resetBackoffThreshold,
double jitterFactor)
Deprecated.
Generates a ExponentialDelayRestartStrategyConfiguration.
|
static RestartStrategies.ExponentialDelayRestartStrategyConfiguration |
exponentialDelayRestart(Time initialBackoff,
Time maxBackoff,
double backoffMultiplier,
Time resetBackoffThreshold,
double jitterFactor)
|
static RestartStrategies.FailureRateRestartStrategyConfiguration |
failureRateRestart(int failureRate,
java.time.Duration failureInterval,
java.time.Duration delayInterval)
Deprecated.
Generates a FailureRateRestartStrategyConfiguration.
|
static RestartStrategies.FailureRateRestartStrategyConfiguration |
failureRateRestart(int failureRate,
Time failureInterval,
Time delayInterval)
Deprecated.
|
static RestartStrategies.RestartStrategyConfiguration |
fallBackRestart()
Deprecated.
|
static RestartStrategies.RestartStrategyConfiguration |
fixedDelayRestart(int restartAttempts,
java.time.Duration delayInterval)
Deprecated.
Generates a FixedDelayRestartStrategyConfiguration.
|
static RestartStrategies.RestartStrategyConfiguration |
fixedDelayRestart(int restartAttempts,
long delayBetweenAttempts)
Deprecated.
Generates a FixedDelayRestartStrategyConfiguration.
|
static RestartStrategies.RestartStrategyConfiguration |
fixedDelayRestart(int restartAttempts,
Time delayInterval)
Deprecated.
|
static Optional<RestartStrategies.RestartStrategyConfiguration> |
fromConfiguration(ReadableConfig configuration)
Deprecated.
Reads a
RestartStrategies.RestartStrategyConfiguration from a given ReadableConfig . |
static RestartStrategies.RestartStrategyConfiguration |
noRestart()
Deprecated.
Generates NoRestartStrategyConfiguration.
|
public static RestartStrategies.RestartStrategyConfiguration noRestart()
public static RestartStrategies.RestartStrategyConfiguration fallBackRestart()
public static RestartStrategies.RestartStrategyConfiguration fixedDelayRestart(int restartAttempts, long delayBetweenAttempts)
restartAttempts
- Number of restart attempts for the FixedDelayRestartStrategydelayBetweenAttempts
- Delay in-between restart attempts for the
FixedDelayRestartStrategy@Deprecated public static RestartStrategies.RestartStrategyConfiguration fixedDelayRestart(int restartAttempts, Time delayInterval)
fixedDelayRestart(int, Duration)
restartAttempts
- Number of restart attempts for the FixedDelayRestartStrategydelayInterval
- Delay in-between restart attempts for the FixedDelayRestartStrategypublic static RestartStrategies.RestartStrategyConfiguration fixedDelayRestart(int restartAttempts, java.time.Duration delayInterval)
restartAttempts
- Number of restart attempts for the FixedDelayRestartStrategydelayInterval
- Delay in-between restart attempts for the FixedDelayRestartStrategy@Deprecated public static RestartStrategies.FailureRateRestartStrategyConfiguration failureRateRestart(int failureRate, Time failureInterval, Time delayInterval)
failureRateRestart(int, Duration, Duration)
failureRate
- Maximum number of restarts in given interval failureInterval
before failing a jobfailureInterval
- Time interval for failuresdelayInterval
- Delay in-between restart attemptspublic static RestartStrategies.FailureRateRestartStrategyConfiguration failureRateRestart(int failureRate, java.time.Duration failureInterval, java.time.Duration delayInterval)
failureRate
- Maximum number of restarts in given interval failureInterval
before failing a jobfailureInterval
- Time interval for failuresdelayInterval
- Delay in-between restart attempts@Deprecated public static RestartStrategies.ExponentialDelayRestartStrategyConfiguration exponentialDelayRestart(Time initialBackoff, Time maxBackoff, double backoffMultiplier, Time resetBackoffThreshold, double jitterFactor)
initialBackoff
- Starting duration between restartsmaxBackoff
- The highest possible duration between restartsbackoffMultiplier
- Delay multiplier how many times is the delay longer than beforeresetBackoffThreshold
- How long the job must run smoothly to reset the time intervaljitterFactor
- How much the delay may differ (in percentage)public static RestartStrategies.ExponentialDelayRestartStrategyConfiguration exponentialDelayRestart(java.time.Duration initialBackoff, java.time.Duration maxBackoff, double backoffMultiplier, java.time.Duration resetBackoffThreshold, double jitterFactor)
initialBackoff
- Starting duration between restartsmaxBackoff
- The highest possible duration between restartsbackoffMultiplier
- Delay multiplier how many times is the delay longer than beforeresetBackoffThreshold
- How long the job must run smoothly to reset the time intervaljitterFactor
- How much the delay may differ (in percentage)public static Optional<RestartStrategies.RestartStrategyConfiguration> fromConfiguration(ReadableConfig configuration)
RestartStrategies.RestartStrategyConfiguration
from a given ReadableConfig
.configuration
- configuration object to retrieve parameters fromOptional.empty()
when no restart strategy parameters providedCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.