flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4653) Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment
Date Wed, 21 Sep 2016 09:41:21 GMT

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

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

GitHub user beyond1920 opened a pull request:

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

    [FLINK-4653] [Client] Refactor JobClientActor to adapt to new Rpc framework and new cluster
managerment

    There are following main changes: 
    1. Create a RpcEndpoint(temporary named JobInfoTracker) and RpcGateway(temporary named
JobInfoTrackerGateway) to replace the old JobClientActor. 
    2. Change rpc message communication in JobClientActor to rpc method call to apply to the
new rpc framework. 
    3. JobInfoTracker is responsible for waiting for the jobStateChange and jobResult util
job complete. 

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

    $ git pull https://github.com/alibaba/flink jira-4653

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

    https://github.com/apache/flink/pull/2524.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 #2524
    
----
commit 5959e94604142784341ba76fb06cccd32473676b
Author: beyond1920 <beyond1920@126.com>
Date:   2016-09-21T06:00:14Z

    jobClient refactor
    
    Summary: jobClient refactor for apply to new cluster management
    
    Test Plan: junit
    
    Reviewers: #blink, kete.yangkt
    
    Differential Revision: http://phabricator.taobao.net/D5816

----


> Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment
> -------------------------------------------------------------------------------------
>
>                 Key: FLINK-4653
>                 URL: https://issues.apache.org/jira/browse/FLINK-4653
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Client
>            Reporter: zhangjing
>            Assignee: zhangjing
>             Fix For: 1.2.0
>
>
> 1. Create a RpcEndpoint(temporary named JobInfoTracker) and RpcGateway(temporary named
JobInfoTrackerGateway) to replace the old JobClientActor. 
> 2. Change rpc message communication in JobClientActor to rpc method call to apply to
the new rpc framework. 
> 3. JobInfoTracker is responsible for waiting for the jobStateChange and jobResult util
job complete. But it is not responsible for submitting new job because jobSubmission behavior
is different in different cluster



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

Mime
View raw message