Aljoscha Krettek created FLINK-4366:
---------------------------------------
Summary: Enforce parallelism=1 For AllWindowedStream
Key: FLINK-4366
URL: https://issues.apache.org/jira/browse/FLINK-4366
Project: Flink
Issue Type: Improvement
Reporter: Aljoscha Krettek
Right now, it is possible to use {{DataStream.windowAll/timeWindowAll}} and
then set a different parallelism afterwards. Flink will silently accept this
and spawn the number of parallel operators, only one instance of those will do
all the processing, though, since the elements are implicitly keyed by a dummy
key.
We should throw an exception if users try to set a parallelism on an
all-windowed stream.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
