pyflink.datastream.checkpoint_config.CheckpointConfig.set_force_unaligned_checkpoints

CheckpointConfig.set_force_unaligned_checkpoints(force_unaligned_checkpoints: bool = True) → pyflink.datastream.checkpoint_config.CheckpointConfig

Checks whether unaligned checkpoints are forced, despite currently non-checkpointable iteration feedback or custom partitioners.

Parameters

force_unaligned_checkpoints – The flag to force unaligned checkpoints.