Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Connectors
    • Formats
  • PyFlink Common

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.

previous

pyflink.datastream.checkpoint_config.CheckpointConfig.is_fail_on_checkpointing_errors

next

pyflink.datastream.checkpoint_config.CheckpointConfig.get_tolerable_checkpoint_failure_number

Show Source

Created using Sphinx 4.5.0.