pyflink.datastream.checkpoint_config.ExternalizedCheckpointCleanup

class ExternalizedCheckpointCleanup(value)

Cleanup behaviour for externalized checkpoints when the job is cancelled.

DELETE_ON_CANCELLATION:

Delete externalized checkpoints on job cancellation.

All checkpoint state will be deleted when you cancel the owning job, both the meta data and actual program state. Therefore, you cannot resume from externalized checkpoints after the job has been cancelled.

Note that checkpoint state is always kept if the job terminates with state FAILED.

RETAIN_ON_CANCELLATION:

Retain externalized checkpoints on job cancellation.

All checkpoint state is kept when you cancel the owning job. You have to manually delete both the checkpoint meta data and actual program state after cancelling the job.

Note that checkpoint state is always kept if the job terminates with state FAILED.

NO_EXTERNALIZED_CHECKPOINTS:

Externalized checkpoints are disabled completely.

Attributes

DELETE_ON_CANCELLATION
RETAIN_ON_CANCELLATION
NO_EXTERNALIZED_CHECKPOINTS