You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/16 15:52:20 UTC

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

     [ https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Stephan Ewen closed FLINK-4366.
-------------------------------

> 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
>            Assignee: Jark Wu
>             Fix For: 1.2.0
>
>
> 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)