[flink] 01/03: [hotfix][benchmarks] fix StreamNetworkThroughputBenchmark#setUp not forwarding localMode

[nkruber]

This is an automated email from the ASF dual-hosted git repository.

nkruber pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git

commit e0b774fc5c24dba356832985e812160cd6f6a603
Author: Nico Kruber <n...@data-artisans.com>
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);
        }
 
        /**