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

Posted to issues@flink.apache.org by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/11 01:41:20 UTC

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

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

Jark Wu reassigned FLINK-4366:
------------------------------

    Assignee: Jark Wu

> 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
>
> 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)