[
https://issues.apache.org/jira/browse/FLINK-16903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073375#comment-17073375
]
Danny Chen commented on FLINK-16903:
------------------------------------
If we want to support parallelism inference, the SupportsCustomParallelism is
necessary, the hint way solves the problem that we mixed the resource and table
options. Also the parallelism is definitely more like an execution config, for
your case, it also need to bind to per-table scope, hint is a choice from my
side.
> Add sink.parallelism for file system factory
> --------------------------------------------
>
> Key: FLINK-16903
> URL: https://issues.apache.org/jira/browse/FLINK-16903
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Runtime
> Reporter: Jingsong Lee
> Priority: Major
> Fix For: 1.11.0
>
>
> A single task may be writing multiple files at the same time. If the
> parallelism is too high, it may lead to a large number of small files. If the
> parallelism is too small, the performance is not enough. This requires that
> the user can specify parallelism.
> * Default is the same as upstream transformation
> * Users can specify parallelism too.
> |‘connector.sink.parallelism’ = ...|
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
