Jingsong Lee created FLINK-16787:
------------------------------------
Summary: Provide an assigner strategy of average splits allocation
Key: FLINK-16787
URL:
https://issues.apache.org/jira/browse/FLINK-16787 Project: Flink
Issue Type: Sub-task
Components: Runtime / Task
Reporter: Jingsong Lee
Fix For: 1.11.0
For now InputSplitAssigner:
Each task is to grab split, rather than average distribution, so once the later tasks are not scheduled, the former tasks will grab all splits.
We can provide an assigner strategy of average splits allocation.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)