[FLINK-22896] Flink sql supports parallelism at the operator level

• Type: New Feature
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Table SQL / Runtime
• Assignee: Unassigned
• Reporter: Fangliang Liu
• Created: 07/Jun/21 06:02
• Updated: 07/Jun/21 07:29

Description

Now DataStream API supports setting parallelism for operators through setParallelism(),

But Table API&SQL can only use global parallelism. 

We should let the Table API&SQL also have the ability to set the appropriate degree of parallelism for each operator on the generated execution graph.

CC becket_qin,jark,Looking forward to your reply, Thanks.

Issue Links

• relates to: FLINK-20670 Support query hints for Flink SQL
• relates to: FLINK-17173 Supports query hint to config "IdleStateRetentionTime" per operator in SQL