You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/19 03:59:20 UTC
[jira] [Commented] (FLINK-4347) Implement SlotManager core

    [ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15427574#comment-15427574 ] 

ASF GitHub Bot commented on FLINK-4347:
---------------------------------------

GitHub user KurtYoung opened a pull request:

    https://github.com/apache/flink/pull/2388

    [FLINK-4347][cluster management] Implement SlotManager core

    Implement some SlotManager's logic mainly in 4 parts:
    * handle slot request initiated by JobMaster
    * sync slot status trigger by TaskExecutor's heartbeat
    * handle slot request failed at TaskExecutor's side
    * handle Resouce(Container) failure (either triggered by some timeout detector or cluster manager master. e.g. yarn master)
    
     I'm not sure whether these logics been implemented too complex, since the local status are not always true due to the distributed environment. The principle i used is: 
     * Always trust TaskExecutor.
     * Generate each action based on the incoming message type (actually, the interface been called) & current information i have. And update local information based on the incoming message.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/KurtYoung/flink jira-4347

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/2388.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2388
    
----
commit d9a055983c3ff7a1c3049c9403c970cf21173061
Author: Kurt Young <yk...@gmail.com>
Date:   2016-08-18T07:48:30Z

    [FLINK-4347][cluster management] Implement SlotManager core

----


> Implement SlotManager core
> --------------------------
>
>                 Key: FLINK-4347
>                 URL: https://issues.apache.org/jira/browse/FLINK-4347
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Cluster Management
>            Reporter: Kurt Young
>            Assignee: Kurt Young
>
> The slot manager is responsible to maintain the list of slot requests and slot allocations. It allows to request slots from the registered TaskExecutors and issues container allocation requests in case that there are not enough available resources.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)