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)