pyflink.datastream.checkpoint_config.CheckpointConfig.set_fail_on_checkpointing_errors#

CheckpointConfig.set_fail_on_checkpointing_errors(fail_on_checkpointing_errors: bool) → pyflink.datastream.checkpoint_config.CheckpointConfig[source]#

Sets the expected behaviour for tasks in case that they encounter an error in their checkpointing procedure. If this is set to true, the task will fail on checkpointing error. If this is set to false, the task will only decline a the checkpoint and continue running. The default is true.

Example:

>>> config.set_fail_on_checkpointing_errors(False)

Parameters: fail_on_checkpointing_errors – True if failing on checkpointing errors, false otherwise.

Note

Deprecated in 2.0. Use set_tolerable_checkpoint_failure_number() instead.