You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/05/22 08:56:00 UTC

[jira] [Created] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

Robert Metzger created FLINK-17883:
--------------------------------------

             Summary: 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


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)