[FLINK-35462] Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator.

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Table SQL / Planner
• Assignee: Unassigned
• Reporter: yuanfenghu
• Created: 27/May/24 07:48
• Updated: 27/May/24 07:50

Description

When using the flinksql connector, we can set the parallelism of the sink. However, when we modify the parallelism of the sink to be the same as the global one, the global chaining strategy may cause the two operators to be linked together, When use checkpoint or savepoint recovery, which will make the task unable to proceed.  we should allow explicit specification of the chaining mode of the connector.
 
Related issues:

https://github.com/apache/iceberg/issues/10371