[jira] [Commented] (FLINK-17079) CsvTableSinkFactoryBase add numFiles and writeMode config when createTableSink

2021-06-01 Thread luoyuxia (Jira)


[ 
https://issues.apache.org/jira/browse/FLINK-17079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355072#comment-17355072
 ] 

luoyuxia commented on FLINK-17079:
--

Configrable numFiles and writeMode is already supported.

> CsvTableSinkFactoryBase add numFiles and writeMode config when createTableSink
> --
>
> Key: FLINK-17079
> URL: https://issues.apache.org/jira/browse/FLINK-17079
> Project: Flink
>  Issue Type: Improvement
>  Components: Connectors / FileSystem, Table SQL / Ecosystem
>Reporter: sulei
>Priority: Minor
>  Labels: pull-request-available
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> when CsvTableSinkFactoryBase create csvTableSink, the numFiles and writeMode 
> use the default value and could not change. this Issue makes the numFiles and 
> writeMode could change by user's config.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (FLINK-17079) CsvTableSinkFactoryBase add numFiles and writeMode config when createTableSink

2021-04-29 Thread Jark Wu (Jira)


[ 
https://issues.apache.org/jira/browse/FLINK-17079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17335648#comment-17335648
 ] 

Jark Wu commented on FLINK-17079:
-

cc [~lirui]

> CsvTableSinkFactoryBase add numFiles and writeMode config when createTableSink
> --
>
> Key: FLINK-17079
> URL: https://issues.apache.org/jira/browse/FLINK-17079
> Project: Flink
>  Issue Type: Improvement
>  Components: Connectors / FileSystem, Table SQL / Ecosystem
>Reporter: sulei
>Priority: Minor
>  Labels: pull-request-available
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> when CsvTableSinkFactoryBase create csvTableSink, the numFiles and writeMode 
> use the default value and could not change. this Issue makes the numFiles and 
> writeMode could change by user's config.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)