pyflink.datastream.checkpoint_config.CheckpointConfig.is_fail_on_checkpointing_errors

CheckpointConfig.is_fail_on_checkpointing_errors() → bool

This determines the behaviour of tasks if there is an error in their local checkpointing. If this returns true, tasks will fail as a reaction. If this returns false, task will only decline the failed checkpoint.

Returns:

True if failing on checkpointing errors, false otherwise.