[FLINK-25582] flink sql kafka source cannot special custom parallelism

• Type: Improvement
• Status: Closed
• Priority: Not a Priority
• Resolution: Duplicate
• Affects Version/s: 1.13.0, 1.14.0
• Component/s: Connectors / Kafka, Table SQL / API
• Labels: auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: venn wu
• Due: 10/Jan/22
• Created: 10/Jan/22 02:27
• Updated: 16/Oct/23 12:46
• Resolved: 16/Oct/23 12:46

Description

when use flink sql api, all operator have same parallelism, but in some times we want specify the source / sink parallelism for kafka source, i noticed the kafka sink already have parameter "sink.parallelism" to specify the sink parallelism, but kafka source no, so we want flink sql api, have a parameter to specify the kafka source parallelism like sink.

Issue Links

• is superceded by: FLINK-33261 FLIP-367: Support Setting Parallelism for Table/SQL Sources
• links to: GitHub Pull Request #18309