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)