[FLINK-1848] Paths containing a Windows drive letter cannot be used in FileOutputFormats

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 0.9
• Fix Version/s: 0.9

Environment

Windows (Cygwin and native)

• Assignee: Fabian Hueske
• Reporter: Fabian Hueske
• Created: 08/Apr/15 13:44
• Updated: 26/May/15 22:42
• Resolved: 26/May/15 22:42

Description

Paths that contain a Windows drive letter such as file:///c:/my/directory cannot be used as output path for FileOutputFormat.

If done, the following exception is thrown:

Caused by: java.lang.IllegalArgumentException: java.net.URISyntaxException: Relative path in absolute URI: file:c:
        at org.apache.flink.core.fs.Path.initialize(Path.java:242)
        at org.apache.flink.core.fs.Path.<init>(Path.java:225)
        at org.apache.flink.core.fs.Path.<init>(Path.java:138)
        at org.apache.flink.core.fs.local.LocalFileSystem.pathToFile(LocalFileSystem.java:147)
        at org.apache.flink.core.fs.local.LocalFileSystem.mkdirs(LocalFileSystem.java:232)
        at org.apache.flink.core.fs.local.LocalFileSystem.mkdirs(LocalFileSystem.java:233)
        at org.apache.flink.core.fs.local.LocalFileSystem.mkdirs(LocalFileSystem.java:233)
        at org.apache.flink.core.fs.local.LocalFileSystem.mkdirs(LocalFileSystem.java:233)
        at org.apache.flink.core.fs.local.LocalFileSystem.mkdirs(LocalFileSystem.java:233)
        at org.apache.flink.core.fs.FileSystem.initOutPathLocalFS(FileSystem.java:603)
        at org.apache.flink.api.common.io.FileOutputFormat.open(FileOutputFormat.java:233)
        at org.apache.flink.api.java.io.CsvOutputFormat.open(CsvOutputFormat.java:158)
        at org.apache.flink.runtime.operators.DataSinkTask.invoke(DataSinkTask.java:183)
        at org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:217)
        at java.lang.Thread.run(Unknown Source)
Caused by: java.net.URISyntaxException: Relative path in absolute URI: file:c:
        at java.net.URI.checkPath(Unknown Source)
        at java.net.URI.<init>(Unknown Source)
        at org.apache.flink.core.fs.Path.initialize(Path.java:240)
        ... 14 more