[FLINK-19937] Support sink parallelism option for all connectors

• Type: New Feature
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Component/s: Table SQL / Ecosystem
• Labels: auto-deprioritized-major pull-request-available
• Assignee: Unassigned
• Reporter: Lsw_aka_laplace
• Created: 03/Nov/20 05:18
• Updated: 07/Jan/22 07:30
• Resolved: 07/Jan/22 07:30

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.

Issue Links

• is a child of: FLINK-19719 [umbrella] FLIP-146: Improve new TableSource and TableSink interfaces
• links to: GitHub Pull Request #13981

Sub-Tasks

• Support sink parallelism configuration to Kafka connector: Closed
• Support sink parallelism configuration to JDBC connector: Closed
• Support sink parallelism configuration to ElasticSearch connector: Closed
• Support sink parallelism configuration to Hive connector: Closed
• Support sink parallelism configuration to FileSystem connector: Closed
• Support sink parallelism configuration to Hbase connector: Closed
• Support sink parallelism configuration to Print connector: Closed