[
https://issues.apache.org/jira/browse/FLINK-31401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17699072#comment-17699072
]
Junrui Li commented on FLINK-31401:
-----------------------------------
[~mbalassi] Thanks so much for your volunteering and contribution!:D As you
said, this is a bug: testTransformationSetParallelism implies that the map and
source should have different parallelism so that they will not be chained
together, but when the default parallelism is 10, it will break the rule.
> testTransformationSetParallelism fails on 10 core machines
> ----------------------------------------------------------
>
> Key: FLINK-31401
> URL: https://issues.apache.org/jira/browse/FLINK-31401
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream, Tests
> Affects Versions: 1.17.0
> Reporter: Márton Balassi
> Assignee: Márton Balassi
> Priority: Minor
> Labels: pull-request-available
>
> StreamingJobGraphGenerator#testTransformationSetParallelism fails if it is
> run in an environment where the default parallelism is 10:
> {noformat}
> org.opentest4j.AssertionFailedError:
> expected: 3
> but was: 2
> Expected :3
> Actual :2
> {noformat}
> The fix is trivial, we need to make an implicit assumption in the test about
> paralellisms explicit.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
