pyflink.datastream.checkpoint_config.CheckpointConfig.set_fail_on_checkpointing_errors

CheckpointConfig.set_fail_on_checkpointing_errors(fail_on_checkpointing_errors: bool) → CheckpointConfig

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.