[
https://issues.apache.org/jira/browse/FLINK-12765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-12765:
----------------------------
Description:
In this version, a task will always requests slot with its own resource need.
If the resource need is less than the default slot resource, it will always be
allocated to a default sized slot.
The extra resources in the slot leaves chances for other tasks within the same
slot sharing group to fit in. To take these chance, SlotPool will maintain
available resources of each allocated slot. Available resource of an allocated
slot should always be the total resource of the slot minus resources of tasks
already assigned onto the slot. In this way, the SlotPool would be able to
determine whether another task can fit into the slot. If a task cannot fit into
the slot, for slot sharing group the SlotPool should request another slot from
the ResourceManager, and for colocation group it should fail the job.
> JobMaster calculates resource needs and requests slot for the entire slot
> sharing group.
> ----------------------------------------------------------------------------------------
>
> Key: FLINK-12765
> URL: https://issues.apache.org/jira/browse/FLINK-12765
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Affects Versions: 1.8.0, 1.9.0
> Reporter: Tony Xintong Song
> Assignee: Yun Gao
> Priority: Major
> Fix For: 1.9.0
>
>
> In this version, a task will always requests slot with its own resource need.
> If the resource need is less than the default slot resource, it will always
> be allocated to a default sized slot.
>
> The extra resources in the slot leaves chances for other tasks within the
> same slot sharing group to fit in. To take these chance, SlotPool will
> maintain available resources of each allocated slot. Available resource of an
> allocated slot should always be the total resource of the slot minus
> resources of tasks already assigned onto the slot. In this way, the SlotPool
> would be able to determine whether another task can fit into the slot. If a
> task cannot fit into the slot, for slot sharing group the SlotPool should
> request another slot from the ResourceManager, and for colocation group it
> should fail the job.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
