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 230fd17f5b271a9e5bdb84ce8a8d360cf407c244 Author: Nico Kruber <[email protected]> AuthorDate: Mon Sep 10 11:05:28 2018 +0200 [hotfix][benchmarks] fix StreamNetworkThroughputBenchmark#setUp not forwarding localMode --- .../runtime/io/benchmark/StreamNetworkThroughputBenchmark.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/StreamNetworkThroughputBenchmark.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/StreamNetworkThroughputBenchmark.java index 1b0ef8a..c55dd43 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/StreamNetworkThroughputBenchmark.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/StreamNetworkThroughputBenchmark.java @@ -60,7 +60,7 @@ public class StreamNetworkThroughputBenchmark { } public void setUp(int recordWriters, int channels, int flushTimeout, boolean localMode) throws Exception { - setUp(recordWriters, channels, flushTimeout, false, -1, -1); + setUp(recordWriters, channels, flushTimeout, localMode, -1, -1); } /**
