[
https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114479#comment-17114479
]
Dian Fu edited comment on FLINK-17883 at 5/23/20, 1:53 AM:
-----------------------------------------------------------
[~jark] [~lzljs3620320] Thanks for your reply. It makes sense to me that the
"insert override" semantics should be specified in the DML instead of DDL. I
just noticed the following interface in StatementSet(since 1.11):
{code}
StatementSet addInsert(String targetPath, Table table, boolean overwrite);
{code}
It has also been supported in the Python Table API. So I think users could
specify "insert overwrite" semantics in both the Java/Python Table API via this
interface since 1.11.
was (Author: dian.fu):
[~jark] [~lzljs3620320] Thanks for your reply. It makes sense to me that the
"insert override" semantics should be specified in the DML instead of DDL. I
just noticed the following interface in StatementSet(since 1.11):
{code}
StatementSet addInsert(String targetPath, Table table, boolean overwrite);
{code}
It's also supported in the Python Table API. So I think users could specify
"insert overwrite" semantics in both the Java/Python Table API via this
interface since 1.11.
> 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)
