(flink) 02/03: [hotfix] UnsupportedOperationException in AdaptiveSchedulerClusterITCase fix

[mapohl]

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

mapohl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 8e7f661ece2354197d4a1e2051df5cb626c19469
Author: Zdenek Tison <zti...@confluent.io>
AuthorDate: Thu Sep 19 10:45:58 2024 +0200

    [hotfix] UnsupportedOperationException in AdaptiveSchedulerClusterITCase fix
---
 .../runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java
index 45da326b6f9..790601b56d0 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java
@@ -258,6 +258,11 @@ public class AdaptiveSchedulerClusterITCase {
         public Future<Void> notifyCheckpointCompleteAsync(long checkpointId) {
             return CompletableFuture.completedFuture(null);
         }
+
+        @Override
+        public Future<Void> notifyCheckpointSubsumedAsync(long checkpointId) {
+            return CompletableFuture.completedFuture(null);
+        }
     }
 
     private JobGraph createBlockingJobGraph(int parallelism) throws 
IOException {