This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch 23879 in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git
commit 15bbd77fb249a6fce0e4576074b55551b995eaaa Author: Chesnay Schepler <[email protected]> AuthorDate: Fri Aug 20 09:18:09 2021 +0200 [FLINK-23879] Fix compilation issue --- .../org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java | 5 +++-- 1 file changed, 3 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..ed0ee84 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,8 @@ 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> {
