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();

Reply via email to