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)

Reply via email to