This is an automated email from the ASF dual-hosted git repository.

sewen pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git

commit a60a4a9c71a2648176ca46a25230920674130d01
Author: Stephan Ewen <[email protected]>
AuthorDate: Wed Jun 24 17:26:55 2020 +0200

    [FLINK-18429][DataStream API] Make 
CheckpointListener.notifyCheckpointAborted(checkpointId) a default method.
    
    This avoid breaking many user programs that use this interface.
---
 .../main/java/org/apache/flink/runtime/state/CheckpointListener.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java
index 13c8e39..ddf2f2d 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java
@@ -45,5 +45,5 @@ public interface CheckpointListener {
         * @param checkpointId The ID of the checkpoint that has been aborted.
         * @throws Exception
         */
-       void notifyCheckpointAborted(long checkpointId) throws Exception;
+       default void notifyCheckpointAborted(long checkpointId) throws 
Exception {};
 }

Reply via email to