Junrui Li created FLINK-30901: --------------------------------- Summary: Fix set jobVertex parallelismConfigured don't contain chained sources. Key: FLINK-30901 URL: https://issues.apache.org/jira/browse/FLINK-30901 Project: Flink Issue Type: Bug Components: Runtime / Coordination Affects Versions: 1.17.0 Reporter: Junrui Li Fix For: 1.17.0
When create OperatorChainInfo in StreamingJobGenerator, the chained source don't include in the chainedNodes and they will not be added to chainInfo via addNodeToChain. This will cause the jobVertex's parallelismConfigured property to be wrong. -- This message was sent by Atlassian Jira (v8.20.10#820010)