[FLINK-32437] Determine and set correct maxParallelism for operator chains - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: In Progress
Priority: Major
Resolution: Unresolved
Affects Version/s: None
Fix Version/s: 2.0.0
Component/s: API / DataStream
Labels:
- pull-request-available
- stale-assigned

Description

Current code in StreamingJobGraphGenerator does not properly determine and set the correct maxParallelism of operator chains. We should set the maxParallelism of the chain as the minimum of all the maxParallelism values among operators in the chain.

Attachments

Issue Links

links to

GitHub Pull Request #22864

Activity

People

Assignee:: Stefan Richter

Reporter:: Stefan Richter

Votes:: 0 Vote for this issue

Watchers:: 2 Start watching this issue

Dates

Created:: 26/Jun/23 08:15

Updated:: 10/Aug/23 22:35