[
https://issues.apache.org/jira/browse/FLINK-30901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-30901:
----------------------------
Description:
When creating OperatorChainInfo in StreamingJobGenerator, the chained source
are not included in OperatorChainInfo#chainedNodes, because they are not added
to OperatorChainInfo via #addNodeToChain().
This will affect jobVertex which has a MultiInput operator chained with
sources. The vertex's parallelismConfigured will be false even if the chained
sources have a parallelism configured.
was:
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.
> The jobVertex's parallelismConfigured is incorrect when chaining with source
> operators
> --------------------------------------------------------------------------------------
>
> 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
> Assignee: Junrui Li
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.17.0
>
>
> When creating OperatorChainInfo in StreamingJobGenerator, the chained source
> are not included in OperatorChainInfo#chainedNodes, because they are not
> added to OperatorChainInfo via #addNodeToChain().
> This will affect jobVertex which has a MultiInput operator chained with
> sources. The vertex's parallelismConfigured will be false even if the chained
> sources have a parallelism configured.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
