Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6244#discussion_r200065001 --- 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 -- probably cleaner to address this issue in a separate commit as the relation isn't obvious.
---