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.


---

Reply via email to