[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011680#comment-17011680 ]
Kostas Kloudas commented on FLINK-15533: ---------------------------------------- Hi [~lirui], I am also try to figure out all the possible scenarios. In addition, I am trying to see if this bug exists also in previous versions of Flink. The reason is that nothing seems to have changed in 1.10 that would change the behaviour of a {{DataStreamSink}}. WDYT? > Writing DataStream as text file fails due to output path already exists > ----------------------------------------------------------------------- > > Key: FLINK-15533 > URL: https://issues.apache.org/jira/browse/FLINK-15533 > Project: Flink > Issue Type: Bug > Components: Client / Job Submission > Affects Versions: 1.10.0 > Reporter: Rui Li > Priority: Blocker > > The following program reproduces the issue. > {code} > Configuration configuration = GlobalConfiguration.loadConfiguration(); > configuration.set(DeploymentOptions.TARGET, RemoteExecutor.NAME); > StreamExecutionEnvironment streamEnv = new > StreamExecutionEnvironment(configuration); > DataStream dataStream = streamEnv.fromCollection(Arrays.asList(1,2,3)); > dataStream.writeAsText("hdfs://localhost:8020/tmp/output"); > streamEnv.execute(); > {code} > The job will fail with the follow error, even though the output path doesn't > exist before job submission: > {noformat} > org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.fs.FileAlreadyExistsException): > /tmp/output already exists as a directory > {noformat} -- This message was sent by Atlassian Jira (v8.3.4#803005)