[FLINK-26358] Operator maxParallelism is lost during chaining

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.14.3, 1.15.0
• Component/s: Runtime / Coordination
• Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: Fabian Paul
• Created: 24/Feb/22 16:00
• Updated: 20/Aug/23 22:35

Description

During the generation of the JobGraph from the StreamGraph the maxParallelism of the chained operators is lost so the maxParallelism written to a snapshot might not reflect the real maxParallelism of the operator.

If a user now unchains the operator it is not possible to restore a snapshot anymore because the maxParallelism of the operator and the snapshot do not match anymore.

Issue Links

• links to: GitHub Pull Request #18926