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 2015/12/07 18:25:12 UTC

[jira] [Resolved] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

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

Stephan Ewen resolved FLINK-2897.
---------------------------------
       Resolution: Fixed
    Fix Version/s: 1.0.0

Fixed via 22ac65ba788b8c5a0c1298d78bfb51ad65d8d00c

Thank you for the contribution!

> Use distinct initial indices for OutputEmitter round-robin
> ----------------------------------------------------------
>
>                 Key: FLINK-2897
>                 URL: https://issues.apache.org/jira/browse/FLINK-2897
>             Project: Flink
>          Issue Type: Improvement
>          Components: Distributed Runtime
>    Affects Versions: 0.10.0
>            Reporter: Greg Hogan
>            Assignee: Greg Hogan
>             Fix For: 1.0.0
>
>
> Currently, when performing a round-robin partitioning each task will sequentially partition starting with partition "1". This is fine in the usual case where the number of partitioned objects greatly exceeds the number of channels. However, in the case where the number of objects is relatively few (each, perhaps, requiring a large computation or access to an external system) it would be much better to begin partitioning at distinct indices (the task index).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)