This is an automated email from the ASF dual-hosted git repository. nkruber pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit fbe816e9700818252aa9462f18d99de00f54b446 Author: Nico Kruber <[email protected]> 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();
