18.Exactly Once
At least once + • •
• •
At least once + • •
• • barrier
•
Region Failover: FLINK-
4256
•
19.
20.•
•
•
•
•
21.•
•
•
•
•
22.
23.
24.
25.
26.
27.
28.public interface CheckpointListener {
/**
* This method is called as a notification once a distributed checkpoint has been completed.
*
* Note that any exception during this method will not cause the checkpoint to
* fail any more.
*
* @param checkpointId The ID of the checkpoint that has been completed.
* @throws Exception
*/
void notifyCheckpointComplete(long checkpointId) throws Exception;
}
