This is an automated email from the ASF dual-hosted git repository. nkruber pushed a commit to branch release-1.5 in repository https://gitbox.apache.org/repos/asf/flink.git
commit f1fc3869cbcf3596eb4604f1d2f347dd483e4ca8 Author: Nico Kruber <n...@data-artisans.com> AuthorDate: Mon Sep 10 09:56:51 2018 +0200 [hotfix][benchmarks] add @Override --- .../flink/streaming/runtime/io/benchmark/SerializingLongReceiver.java | 1 + 1 file changed, 1 insertion(+) diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/SerializingLongReceiver.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/SerializingLongReceiver.java index 580612c..a93e9d2 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/SerializingLongReceiver.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/SerializingLongReceiver.java @@ -40,6 +40,7 @@ public class SerializingLongReceiver extends ReceiverThread { }); } + @Override protected void readRecords(long lastExpectedRecord) throws Exception { LOG.debug("readRecords(lastExpectedRecord = {})", lastExpectedRecord); final LongValue value = new LongValue();