[ https://issues.apache.org/jira/browse/FLINK-19262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee closed FLINK-19262. -------------------------------- Resolution: Fixed master: 49e3ff72e7fb06360c02578e30fa03cce24ca04f > Can not setParallelism for FLIP-27 source > ----------------------------------------- > > Key: FLINK-19262 > URL: https://issues.apache.org/jira/browse/FLINK-19262 > Project: Flink > Issue Type: Bug > Components: API / DataStream > Reporter: Jingsong Lee > Assignee: liufangliang > Priority: Critical > Labels: pull-request-available > Fix For: 1.12.0 > > > The constructor for new Sources in {{DataStreamSource}} does not set > isParallel to true. So if we setParallelism for FLIP-27 source, there will be > a validation exception from validateParallelism. -- This message was sent by Atlassian Jira (v8.3.4#803005)