rkhachatryan commented on a change in pull request #8693:
URL: https://github.com/apache/flink/pull/8693#discussion_r425330030
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java
##########
@@ -38,4 +38,12 @@
* @throws Exception
*/
void notifyCheckpointComplete(long checkpointId) throws Exception;
+
+ /**
+ * This method is called as a notification once a distributed
checkpoint has been aborted.
+ *
+ * @param checkpointId The ID of the checkpoint that has been aborted.
+ * @throws Exception
+ */
+ default void notifyCheckpointAborted(long checkpointId) throws
Exception {}
Review comment:
As there are already such state backends, as @Myasuka mentioned below,
it makes sense
(regarding multiple interfaces, they can simply be combined (with `extends`)
and given to the user).
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
