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)