[flink] 02/02: [hotfix][tests] Prevent HistoryServerTest to print to STDOUT

[trohrmann]

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

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

commit 81940809ea64bc8b1743f0c57860a10743430ed8
Author: Till Rohrmann <trohrm...@apache.org>
AuthorDate: Tue Apr 30 15:29:28 2019 +0200

    [hotfix][tests] Prevent HistoryServerTest to print to STDOUT
---
 .../apache/flink/runtime/webmonitor/history/HistoryServerTest.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java
 
b/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java
index 58f8f2b..03bcfa8 100644
--- 
a/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java
+++ 
b/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java
@@ -28,6 +28,7 @@ import 
org.apache.flink.runtime.messages.webmonitor.MultipleJobsDetails;
 import org.apache.flink.runtime.rest.messages.JobsOverviewHeaders;
 import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
+import org.apache.flink.streaming.api.functions.sink.DiscardingSink;
 import org.apache.flink.test.util.MiniClusterWithClientResource;
 import org.apache.flink.util.TestLogger;
 
@@ -145,8 +146,7 @@ public class HistoryServerTest extends TestLogger {
 
        private static void runJob() throws Exception {
                StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();
-               env.fromElements(1, 2, 3)
-                       .print();
+               env.fromElements(1, 2, 3).addSink(new DiscardingSink<>());
 
                env.execute();
        }