Greg Hogan created FLINK-2897:
---------------------------------

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

Reply via email to