You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Junrui Li (Jira)" <ji...@apache.org> on 2023/02/06 03:22:00 UTC

[jira] [Created] (FLINK-30901) Fix set jobVertex parallelismConfigured don't contain chained sources.

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)