@Internal public interface InternalCheckpointListener extends CheckpointListener
notifyCheckpointSubsumed(long)interface for internal usage.
|Modifier and Type||Method and Description|
This method is called as a notification once a distributed checkpoint has been subsumed.
void notifyCheckpointSubsumed(long checkpointId) throws Exception
These notifications are "best effort", meaning they can sometimes be skipped.
This method is very rarely necessary to implement. The "best effort" guarantee, together with the fact that this method should not result in discarding any data (per the "Checkpoint Subsuming Contract") means it is mainly useful for earlier cleanups of auxiliary resources.
checkpointId- The ID of the checkpoint that has been subsumed.
Exception- This method can propagate exceptions, which leads to a failure/recovery for the task or job.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.