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

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

GitHub user tillrohrmann opened a pull request:

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

    [FLINK-4343] [tm] Implement TM -> JM registration logic

    Upon requesting a slot for a new job, the TaskManager registers this job at 
the
    `JobLeaderService`. The job leader service is responsible to monitor job 
leader changes
    for all registered jobs. In case of a new job leader, the service will try 
to establish
    a connection to the new job leader. Upon establishing the connection the 
task manager
    is informed about it. The task manager will then offer all allocated but 
not yet active
    slots to the new job leader.

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

    $ git pull https://github.com/tillrohrmann/flink taskManagerRegistration

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

    https://github.com/apache/flink/pull/2640.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 #2640
    
----
commit aafd9020eae2769fd0ade9d922683aac2886412a
Author: Till Rohrmann <trohrm...@apache.org>
Date:   2016-10-05T15:02:06Z

    [FLINK-4343] [tm] Implement TM -> JM registration logic
    
    Upon requesting a slot for a new job, the TaskManager registers this job at 
the
    JobLeaderService. The job leader service is responsible to monitor job 
leader changes
    for all registered jobs. In case of a new job leader, the service will try 
to establish
    a connection to the new job leader. Upon establishing the connection the 
task manager
    is informed about it. The task manager will then offer all allocated but 
not yet active
    slots to the new job leader.
    
    Implement JobLeaderService
    
    The JobLeaderService is responsible for establishing a connection to the JM 
leader of a given
    job.
    
    Disable TaskExecutorTest#testRejectAllocationRequestsForOutOfSyncSlots
    
    Add simple task submission test
    
    Add job leader detection test case
    
    Add task slot acceptance test
    
    Fix RpcCompletenessTest
    
    Add comments

----


> Implement new TaskManager
> -------------------------
>
>                 Key: FLINK-4343
>                 URL: https://issues.apache.org/jira/browse/FLINK-4343
>             Project: Flink
>          Issue Type: New Feature
>          Components: Cluster Management
>            Reporter: Stephan Ewen
>
> This is the parent issue for the efforts to implement the {{TaskManager}} 
> changes based on FLIP-6 
> (https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65147077)
> Because of the breadth of changes, we should implement a new version of the 
> {{TaskManager}} (let's call it {{TaskExecutor}}) rather than updating the 
> current {{TaskManager}}. That will allow us to keep a working master branch.
> At the point when the new cluster management is on par with the current 
> implementation, we will drop the old {{TaskManager}} and rename the 
> {{TaskExecutor}} to {{TaskManager}}.



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

Reply via email to