pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.set_restart_strategy

StreamExecutionEnvironment.set_restart_strategy(restart_strategy_configuration: pyflink.common.restart_strategy.RestartStrategyConfiguration)

Sets the restart strategy configuration. The configuration specifies which restart strategy will be used for the execution graph in case of a restart.

Example:

>>> env.set_restart_strategy(RestartStrategies.no_restart())

Parameters

restart_strategy_configuration – Restart strategy configuration to be set.

Returns