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.
---