pyflink.datastream.checkpoint_config.CheckpointConfig.set_tolerable_checkpoint_failure_number

CheckpointConfig.set_tolerable_checkpoint_failure_number(tolerable_checkpoint_failure_number: int) → CheckpointConfig

This defines how many consecutive checkpoint failures will be tolerated, before the whole job is failed over. The default value is 0, which means no checkpoint failures will be tolerated, and the job will fail on first reported checkpoint failure.

Example:

>>> config.set_tolerable_checkpoint_failure_number(2)

Parameters:

tolerable_checkpoint_failure_number – The maximum number of tolerated checkpoint failures.