org.apache.flink.runtime.jobgraph

Class SavepointConfigOptions

java.lang.Object

org.apache.flink.runtime.jobgraph.SavepointConfigOptions

@PublicEvolving
public class SavepointConfigOptions
extends Object

The configuration options used when restoring from a savepoint.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<RestoreMode>	RESTORE_MODE Describes the mode how Flink should restore from the given savepoint or retained checkpoint.
static ConfigOption<Boolean>	SAVEPOINT_IGNORE_UNCLAIMED_STATE A flag indicating if we allow Flink to skip savepoint state that cannot be restored, e.g.
static ConfigOption<String>	SAVEPOINT_PATH The path to a savepoint that will be used to bootstrap the pipeline's state.

Constructor Summary

Constructors

Constructor and Description
SavepointConfigOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

SAVEPOINT_PATH

public static final ConfigOption<String> SAVEPOINT_PATH

The path to a savepoint that will be used to bootstrap the pipeline's state.

SAVEPOINT_IGNORE_UNCLAIMED_STATE

public static final ConfigOption<Boolean> SAVEPOINT_IGNORE_UNCLAIMED_STATE

A flag indicating if we allow Flink to skip savepoint state that cannot be restored, e.g. because the corresponding operator has been removed.

RESTORE_MODE

public static final ConfigOption<RestoreMode> RESTORE_MODE

Describes the mode how Flink should restore from the given savepoint or retained checkpoint.

Constructor Detail

SavepointConfigOptions

public SavepointConfigOptions()