[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lsw_aka_laplace updated FLINK-19937: ------------------------------------ Description: Since https://issues.apache.org/jira/browse/FLINK-19727 has been done. SINK_PARALLELISM option and `ParallelismProvider` should be applied for all existing `DynamicTableSink` of connectors in order to give users access to setting their own sink parallelism. Update: Anybody who works on this issue should refrence to FLINK-19727~ `ParallelismProvider` should work with `SinkRuntimeProvider`, actually `SinkFunctionProvider` and `OutputFormatProvider` has implemented `ParallelismProvider`. And `SINK_PARALLELISM` has already defined in `FactoryUtil`, plz reuse it. was: Since https://issues.apache.org/jira/browse/FLINK-19727 has been done. SINK_PARALLELISM option and `ParallelismProvider` should be applied for all existing `DynamicTableSink` of connectors in order to give users access to setting their own sink parallelism. > Support sink parallelism option for all connectors > -------------------------------------------------- > > Key: FLINK-19937 > URL: https://issues.apache.org/jira/browse/FLINK-19937 > Project: Flink > Issue Type: New Feature > Components: Table SQL / Ecosystem > Reporter: Lsw_aka_laplace > Priority: Major > > Since https://issues.apache.org/jira/browse/FLINK-19727 has been done. > SINK_PARALLELISM option and `ParallelismProvider` should be applied for all > existing `DynamicTableSink` of connectors in order to give users access to > setting their own sink parallelism. > > > Update: > Anybody who works on this issue should refrence to FLINK-19727~ > `ParallelismProvider` should work with `SinkRuntimeProvider`, actually > `SinkFunctionProvider` and `OutputFormatProvider` has implemented > `ParallelismProvider`. And `SINK_PARALLELISM` has already defined in > `FactoryUtil`, plz reuse it. -- This message was sent by Atlassian Jira (v8.3.4#803005)