[flink-benchmarks] branch master updated: [FLINK-23879] Fix compilation issue

[chesnay]

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

chesnay 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 076aee6  [FLINK-23879] Fix compilation issue
076aee6 is described below

commit 076aee63e98236cc7687f171899f1da25c748d24
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Fri Aug 20 10:22:46 2021 +0200

    [FLINK-23879] Fix compilation issue
---
 .../org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java 
b/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java
index 696a40d..3a0af48 100644
--- 
a/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java
+++ 
b/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java
@@ -44,7 +44,7 @@ import 
org.apache.flink.streaming.api.operators.TwoInputStreamOperator;
 import 
org.apache.flink.streaming.api.transformations.KeyedMultipleInputTransformation;
 import org.apache.flink.streaming.runtime.streamrecord.LatencyMarker;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
-import org.apache.flink.streaming.runtime.streamstatus.StreamStatus;
+import org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus;
 import org.apache.flink.util.SplittableIterator;
 
 import org.junit.Assert;
@@ -347,7 +347,7 @@ public class SortingBoundedInputBenchmarks extends 
BenchmarkBase {
         public void setKeyContextElement(StreamRecord<Integer> record) {}
 
         @Override
-        public void processStreamStatus(StreamStatus streamStatus) throws 
Exception {}
+        public void processWatermarkStatus(WatermarkStatus watermarkStatus) 
throws Exception {}
     }
 
     private static class InputGenerator extends SplittableIterator<Integer> {