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.


---

Reply via email to