[jira] [Created] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream

[Shang Yuanchun (Jira)]

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)