flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin
Date Thu, 22 Oct 2015 20:09:27 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14969807#comment-14969807
] 

ASF GitHub Bot commented on FLINK-2897:
---------------------------------------

GitHub user greghogan opened a pull request:

    https://github.com/apache/flink/pull/1292

    [FLINK-2897] [runtime] Use distinct initial indices for OutputEmitter round-robin

    

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/greghogan/flink 2897_use_distinct_initial_indices_for_outputemitter_round_robin

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/1292.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #1292
    
----
commit 6365e693a69810cf1597a2f19191d08b6e644da8
Author: Greg Hogan <code@greghogan.com>
Date:   2015-10-22T14:43:26Z

    [FLINK-2897] [runtime] Use distinct initial indices for OutputEmitter round-robin

----


> 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
>            Reporter: Greg Hogan
>            Assignee: Greg Hogan
>
> 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)

Mime
View raw message