[flink-benchmarks] branch master updated: [hotfix] Fix compilation after 2b2f943fa05b616b343d437aec7685f6aac33752

[dwysakowicz]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new be7fbf3  [hotfix] Fix compilation after 
2b2f943fa05b616b343d437aec7685f6aac33752
be7fbf3 is described below

commit be7fbf3347f2f2674b3fb484ac84809bf25aab21
Author: Dawid Wysakowicz <dwysakow...@apache.org>
AuthorDate: Thu Jun 17 13:50:52 2021 +0200

    [hotfix] Fix compilation after 2b2f943fa05b616b343d437aec7685f6aac33752
---
 .../java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 class SortingBoundedInputBenchmarks extends 
BenchmarkBase {
         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> {