yuanfenghu created FLINK-35462: ---------------------------------- Summary: Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator. Key: FLINK-35462 URL: https://issues.apache.org/jira/browse/FLINK-35462 Project: Flink Issue Type: Improvement Components: Table SQL / Planner Reporter: yuanfenghu
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, which will make the task unable to proceed. For checkpoint or savepoint recovery, we should allow explicit specification of the chaining mode of the connector. Related issues: https://github.com/apache/iceberg/issues/10371 -- This message was sent by Atlassian Jira (v8.20.10#820010)