public final class RestartStrategyResolving extends Object
RestartStrategy
.Modifier and Type | Method and Description |
---|---|
static RestartStrategy |
resolve(RestartStrategies.RestartStrategyConfiguration clientConfiguration,
RestartStrategyFactory serverStrategyFactory,
boolean isCheckpointingEnabled)
Resolves which
RestartStrategy to use. |
public static RestartStrategy resolve(RestartStrategies.RestartStrategyConfiguration clientConfiguration, RestartStrategyFactory serverStrategyFactory, boolean isCheckpointingEnabled)
RestartStrategy
to use. It should be used only on the server side.
The resolving strategy is as follows:
NoRestartStrategy
and checkpointing
is enabled.FixedDelayRestartStrategy
is usedclientConfiguration
- restart configuration given within the job graphserverStrategyFactory
- default server side strategy factoryisCheckpointingEnabled
- if checkpointing was enabled for the jobCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.