Repository: flink Updated Branches: refs/heads/master a3bc2bdc6 -> 2fd2ccb65
[hotfix] Let DistributedCacheDfsTest extend TestLogger and avoid stdout output Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2fd2ccb6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2fd2ccb6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2fd2ccb6 Branch: refs/heads/master Commit: 2fd2ccb65fb213f251425265b6319b1e740a471a Parents: acb8edc Author: Till Rohrmann <trohrm...@apache.org> Authored: Wed Jul 4 12:13:17 2018 +0200 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Wed Jul 4 12:13:48 2018 +0200 ---------------------------------------------------------------------- .../org/apache/flink/hdfstests/DistributedCacheDfsTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/2fd2ccb6/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/DistributedCacheDfsTest.java ---------------------------------------------------------------------- diff --git a/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/DistributedCacheDfsTest.java b/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/DistributedCacheDfsTest.java index ed4ec94..4c8440d 100644 --- a/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/DistributedCacheDfsTest.java +++ b/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/DistributedCacheDfsTest.java @@ -23,9 +23,11 @@ import org.apache.flink.core.fs.FileStatus; import org.apache.flink.core.fs.FileSystem; import org.apache.flink.core.fs.Path; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; +import org.apache.flink.streaming.api.functions.sink.DiscardingSink; import org.apache.flink.test.util.MiniClusterResource; import org.apache.flink.test.util.MiniClusterResourceConfiguration; import org.apache.flink.util.NetUtils; +import org.apache.flink.util.TestLogger; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hdfs.MiniDFSCluster; @@ -48,7 +50,7 @@ import static org.junit.Assert.assertTrue; /** * Tests for distributing files with {@link org.apache.flink.api.common.cache.DistributedCache} via HDFS. */ -public class DistributedCacheDfsTest { +public class DistributedCacheDfsTest extends TestLogger { private static final String testFileContent = "Goethe - Faust: Der Tragoedie erster Teil\n" + "Prolog im Himmel.\n" + "Der Herr. Die himmlischen Heerscharen. Nachher Mephistopheles. Die drei\n" + "Erzengel treten vor.\n" @@ -128,7 +130,7 @@ public class DistributedCacheDfsTest { env.fromElements(1) .map(new TestMapFunction()) - .print(); + .addSink(new DiscardingSink<>()); env.execute("Distributed Cache Via Blob Test Program"); }
