flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream
Date Tue, 16 Aug 2016 15:52:20 GMT

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

Stephan Ewen resolved FLINK-4366.
       Resolution: Fixed
    Fix Version/s: 1.2.0

Fixed via ffe406570af60057fa2ae318561aa239b99bd648

> 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

View raw message