hi, I have a problem that Flink deletes checkpoint information on
kubernetes HA setup even if
execution.checkpointing.externalized-checkpoint-retention=RETAIN_ON_CANCELLATION
is set.
config documentation:
"RETAIN_ON_CANCELLATION": Checkpoint state is kept when the owning job is
cancelled or fails.
but in the kubernetes implementation:
https://github.com/apache/flink/blob/master/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesCheckpointIDCounter.java#L82-L84
        LOG.info("Shutting down.");
        if (jobStatus.isGloballyTerminalState()) {
            LOG.info("Removing counter from ConfigMap {}", configMapName);
on termination, it removes the counter from the configmap that seems to be
important to recover checkpoints.
Is this correct behaviour? (Flink 1.17.2 in our case). The jobmanager pod
is shut down via pod eviction, with a terminationGracePeriodSeconds of 30s.


2024-07-11 08:18:45,866 INFO
 org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool []
- Releasing slot [3c92e4ee1303da214e868fcef5d4ad91].
2024-07-11 08:19:08,335 INFO
 org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - RECEIVED
SIGNAL 15: SIGTERM. Shutting down as requested.
2024-07-11 08:19:08,336 INFO
 org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Shutting
StandaloneApplicationClusterEntryPoint down with application status
UNKNOWN. Diagnostics Cluster entrypoint has been closed externally..
2024-07-11 08:19:08,922 INFO
 org.apache.flink.kubernetes.highavailability.KubernetesCheckpointIDCounter
[] - Shutting down.
2024-07-11 08:19:08,922 INFO
 org.apache.flink.kubernetes.highavailability.KubernetesCheckpointIDCounter
[] - Removing counter from ConfigMap
flink-fuzzy-wifibissid-counter-pax-cluster-da512a1587e13e9ef844938ede5adab8-config-map

-- 


By communicating with Grab Holdings Limited and/or its subsidiaries, 
associate companies and jointly controlled entities (collectively, “Grab”), 
you are deemed to have consented to the processing of your personal data as 
set out in the Privacy Notice which can be viewed at 
https://grab.com/privacy/  <https://grab.com/privacy/>


 This email 
contains confidential information that may be privileged and is only for 
the intended recipient(s). If you are not the intended recipient(s), please 
do not disseminate, distribute or copy this email. Please notify Grab 
immediately if you have received this by mistake and delete this email from 
your system. Email transmission may not be secure or error-free as any 
information could be intercepted, corrupted, lost, destroyed, delayed or 
incomplete, or contain viruses. Grab does not accept liability for any 
errors or omissions in this email that arise as a result of email 
transmission. All intellectual property rights in this email and any 
attachments shall remain vested in Grab, unless otherwise provided by law

Reply via email to