[jira] [Created] (FLINK-16664) Unable to set DataStreamSource parallelism to default (-1)

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-16664) Unable to set DataStreamSource parallelism to default (-1)

Shang Yuanchun (Jira)
Nico Kruber created FLINK-16664:
-----------------------------------

             Summary: Unable to set DataStreamSource parallelism to default (-1)
                 Key: FLINK-16664
                 URL: https://issues.apache.org/jira/browse/FLINK-16664
             Project: Flink
          Issue Type: Bug
          Components: API / DataStream
    Affects Versions: 1.10.0
            Reporter: Nico Kruber
            Assignee: Nico Kruber
             Fix For: 1.10.1, 1.11.0


A hotfix part of FLINK-14405 actually breaks setting the parallelism to its default value for datastream sources, i.e. using value {{-1}}. This is because of a small typo: instead of
{code:java}
OperatorValidationUtils.validateParallelism(parallelism, isParallel);  {code}
this is called in org.apache.flink.streaming.api.datastream.DataStreamSource#setParallelism:
{code:java}
OperatorValidationUtils.validateMaxParallelism(parallelism, isParallel); {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)