commit be7fbf3347f2f2674b3fb484ac84809bf25aab21
author Dawid Wysakowicz <dwysakowicz@apache.org> Thu Jun 17 13:50:52 2021 +0200
committer Dawid Wysakowicz <dwysakowicz@apache.org> Thu Jun 17 13:50:52 2021 +0200
tree a5c5e143f33c5012abea7f25e064794089d2eeba
parent 66b6c7c90bfa6c994b9d76fa286b4ea08f69d8cb

[hotfix] Fix compilation after 2b2f943fa05b616b343d437aec7685f6aac33752

src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java

diff --git a/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java b/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java
index ad955e0..696a40d 100644
--- a/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java
+++ b/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java
@@ -347,7 +347,7 @@
         public void setKeyContextElement(StreamRecord<Integer> record) {}
 
         @Override
-        public void emitStreamStatus(StreamStatus streamStatus) throws Exception {}
+        public void processStreamStatus(StreamStatus streamStatus) throws Exception {}
     }
 
     private static class InputGenerator extends SplittableIterator<Integer> {