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)