Repository: flink Updated Branches: refs/heads/master 0e0c40d8a -> f1e9daece
[FLINK-4276] Fix TextInputFormatTest#testNestedFileRead This closes #2312 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a2219b0b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a2219b0b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a2219b0b Branch: refs/heads/master Commit: a2219b0b6258077fedc355d71d1846e3142d3e15 Parents: 0e0c40d Author: zentol <ches...@apache.org> Authored: Fri Jul 29 14:48:28 2016 +0200 Committer: zentol <ches...@apache.org> Committed: Mon Aug 8 15:10:38 2016 +0200 ---------------------------------------------------------------------- .../java/org/apache/flink/api/java/io/TextInputFormatTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/a2219b0b/flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java ---------------------------------------------------------------------- diff --git a/flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java b/flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java index 3cb7505..4a52eea 100644 --- a/flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java +++ b/flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java @@ -36,6 +36,7 @@ import java.util.List; import org.apache.flink.configuration.Configuration; import org.apache.flink.core.fs.FileInputSplit; +import org.apache.flink.core.fs.FileSystem; import org.apache.flink.core.fs.Path; import org.junit.Test; @@ -103,7 +104,7 @@ public class TextInputFormatTest { File tempFile = File.createTempFile("TextInputFormatTest", ".tmp", tmpDir); tempFile.deleteOnExit(); - expectedFiles.add("file:" + tempFile.getAbsolutePath()); + expectedFiles.add(new Path(tempFile.getAbsolutePath()).makeQualified(FileSystem.getLocalFileSystem()).toString()); } File parentDir = new File("tmp");
