Hi Wu,
The basic idea of checkpoints is that they are fully managed by Flink and
only used for fault tolerance. Hence, if a job is stopped, there should not
be any checkpoint lingering around.
Savepoints on the other hand or snapshots that are managed by the user, and
can be used to start a new jo
Dear Flinkers:
As "CheckpointProperties#CHECKPOINT_RETAINED_ON_CANCELLATION" shows,
if Job stopped with JobStatus#FINISHED "CompletedCheckpointStore" will
discard all completed checkpoints.
My question is, why job on the FINISHED status the
CompletedCheckpointStore discard all completed che
