(flink) branch master updated: [hotfix] Fix compile error in EventTimeWatermarkHandlerTest (#26007)

[leiyanfei]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 9b411b3f1f7 [hotfix] Fix compile error in 
EventTimeWatermarkHandlerTest (#26007)
9b411b3f1f7 is described below

commit 9b411b3f1f7f2caae7e653e7630386376e13bcc3
Author: Yanfei Lei <fredia...@gmail.com>
AuthorDate: Sat Jan 18 00:09:10 2025 +0800

    [hotfix] Fix compile error in EventTimeWatermarkHandlerTest (#26007)
---
 .../extension/eventtime/EventTimeWatermarkHandlerTest.java    | 11 -----------
 1 file changed, 11 deletions(-)

diff --git 
a/flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/extension/eventtime/EventTimeWatermarkHandlerTest.java
 
b/flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/extension/eventtime/EventTimeWatermarkHandlerTest.java
index 2ab186cbd2e..36c987701cd 100644
--- 
a/flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/extension/eventtime/EventTimeWatermarkHandlerTest.java
+++ 
b/flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/extension/eventtime/EventTimeWatermarkHandlerTest.java
@@ -22,7 +22,6 @@ import org.apache.flink.api.common.watermark.BoolWatermark;
 import org.apache.flink.api.common.watermark.LongWatermark;
 import org.apache.flink.api.common.watermark.Watermark;
 import org.apache.flink.datastream.api.extension.eventtime.EventTimeExtension;
-import org.apache.flink.runtime.asyncprocessing.AsyncExecutionController;
 import org.apache.flink.runtime.event.WatermarkEvent;
 import org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream;
 import org.apache.flink.streaming.api.operators.InternalTimeServiceManager;
@@ -263,16 +262,6 @@ class EventTimeWatermarkHandlerTest {
             throw new UnsupportedOperationException();
         }
 
-        @Override
-        public <N> InternalTimerService<N> getAsyncInternalTimerService(
-                String name,
-                TypeSerializer<Long> keySerializer,
-                TypeSerializer<N> namespaceSerializer,
-                Triggerable<Long, N> triggerable,
-                AsyncExecutionController<Long> asyncExecutionController) {
-            throw new UnsupportedOperationException();
-        }
-
         @Override
         public void 
advanceWatermark(org.apache.flink.streaming.api.watermark.Watermark watermark)
                 throws Exception {