[
https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113962#comment-17113962
]
Dian Fu commented on FLINK-17883:
---------------------------------
I take a quick look at the code and I guess the reason is that the Java Csv
descriptor hasn't provided an interface to set the write mode. Adding such an
interface at Python side alone is feasible, however, it would be great if we
can align the Python API with the Java API.
cc [~docete] I'm assuming you are more familiar with this as I noticed that you
added the write mode property in the csv table sink. Could you kindly share
some thoughts on this? Is there any reason why not allowing to set the write
mode in the Csv descriptor?
> 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)
