Package org.apache.flink.runtime.executiongraph.failover

Class RestartBackoffTimeStrategyFactoryLoader

java.lang.Object

org.apache.flink.runtime.executiongraph.failover.RestartBackoffTimeStrategyFactoryLoader

public final class RestartBackoffTimeStrategyFactoryLoader
extends Object

A utility class to load RestartBackoffTimeStrategy.Factory from the configuration.

Method Summary

Modifier and Type	Method	Description
static RestartBackoffTimeStrategy.Factory	createRestartBackoffTimeStrategyFactory(Configuration jobConfiguration, Configuration clusterConfiguration, boolean isCheckpointingEnabled)	Creates RestartBackoffTimeStrategy.Factory from the given configuration.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createRestartBackoffTimeStrategyFactory

public static RestartBackoffTimeStrategy.Factory createRestartBackoffTimeStrategyFactory(Configuration jobConfiguration,
                                                                                         Configuration clusterConfiguration,
                                                                                         boolean isCheckpointingEnabled)

Creates RestartBackoffTimeStrategy.Factory from the given configuration.

The strategy factory is decided in order as follows:

1. Strategy set in the job-level config
2. Strategy set in the cluster(server-side) config (config.yaml), unless the strategy is not specified
3. FixedDelayRestartBackoffTimeStrategy.FixedDelayRestartBackoffTimeStrategyFactory if checkpointing is enabled. Otherwise NoRestartBackoffTimeStrategy.NoRestartBackoffTimeStrategyFactory

Parameters:

jobConfiguration - job configuration

clusterConfiguration - cluster(server-side) configuration

isCheckpointingEnabled - if checkpointing is enabled for the job

Returns:

new version restart strategy factory