[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114089#comment-17114089 ]
Jingsong Lee commented on FLINK-17883: -------------------------------------- Hi [~jark], you are right, we can use new filesystem connector by DDL. But PyFlink mapping Descriptor to python api, and we will support descriptor for new connector properties (Defined in FLIP-122) in FLINK 1.12. > 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 > Assignee: Nicholas Jiang > 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)