[FLINK-18429][DataStream API] Make CheckpointListener.notifyCheckpoin…

…tAborted(checkpointId) a default method. This avoid breaking many user programs that use this interface. This closes apache#12767
spotify · Jun 24, 2020 · 4776813 · 4776813
1 parent ca53401
commit 4776813
Showing 1 changed file with 1 addition and 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
@@ -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 {};
 }