[hotfix] Fix compile error in EventTimeWatermarkHandlerTest (#26007)

apache · Jan 17, 2025 · 9b411b3 · 9b411b3
1 parent 26d3426
commit 9b411b3
Showing 1 changed file with 0 additions and 11 deletions.
diff --git a/...link/test/streaming/api/datastream/extension/eventtime/EventTimeWatermarkHandlerTest.java b/...link/test/streaming/api/datastream/extension/eventtime/EventTimeWatermarkHandlerTest.java
@@ -22,7 +22,6 @@
 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 @@ public <N> InternalTimerService<N> getInternalTimerService(
             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 {