[ 
https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113880#comment-17113880
 ] 

Nicholas Jiang commented on FLINK-17883:
----------------------------------------

[~rmetzger], I don't agree with you any more. I previously need to overwrite 
filesystem but python api doesn't support this. I would like to try this issue 
for my business case.

> Unable to configure write mode for FileSystem() connector in PyFlink
> --------------------------------------------------------------------
>
>                 Key: FLINK-17883
>                 URL: https://issues.apache.org/jira/browse/FLINK-17883
>             Project: Flink
>          Issue Type: Improvement
>          Components: API / Python
>    Affects Versions: 1.10.1
>            Reporter: Robert Metzger
>            Priority: Major
>
> As a user of PyFlink, I'm getting the following exception:
> {code}
> File or directory /tmp/output already exists. Existing files and directories 
> are not overwritten in NO_OVERWRITE mode. Use OVERWRITE mode to overwrite 
> existing files and directories.
> {code}
> I would like to be able to configure writeMode = OVERWRITE for the FileSystem 
> connector.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to