Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6244#discussion_r200073559 --- Diff: flink-fs-tests/src/test/java/org/apache/flink/hdfstests/DistributedCacheDfsTest.java --- @@ -128,7 +130,7 @@ public void testDistributeFileViaDFS() throws Exception { env.fromElements(1) .map(new TestMapFunction()) - .print(); + .addSink(new DiscardingSink<>()); --- End diff -- True, will change the PR accordingly.
---