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

Reply via email to