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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Shang Yuanchun (Jira)
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)