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-4375) Introduce rpc protocols implemented by job manager
Date Tue, 16 Aug 2016 03:49:20 GMT

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

ASF GitHub Bot commented on FLINK-4375:

GitHub user wenlong88 opened a pull request:


    [FLINK-4375][cluster management]Introduce rpc protocols implemented by job manager

    1. Add basic RPC interface provided by job master including
    2. improve RpcCompletenessTest to support RpcGateway inheriting other gateways

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

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

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


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

    This closes #2375
commit b9fd92697478ffc81a9f6ee7b3b14edfab5a02f2
Author: wenlong.lwl <wenlong.lwl@alibaba-inc.com>
Date:   2016-08-12T11:40:17Z

    add Job Master RPC protocols

commit e6c463e1c55cb9269fa549ca6abd439707c833f5
Author: wenlong.lwl <wenlong.lwl@alibaba-inc.com>
Date:   2016-08-15T02:42:42Z

    Merge branch 'flip-6' of github.com:apache/flink into flip-6

commit 573bf635d8912610b9cbcc58d3081a899c894999
Author: wenlong.lwl <wenlong.lwl@alibaba-inc.com>
Date:   2016-08-15T06:00:33Z

    do some refactor on job master gateway interface

commit fe29f628f02ed01489e3051de63207b8dd6c53d0
Author: wenlong.lwl <wenlong.lwl@alibaba-inc.com>
Date:   2016-08-15T07:14:40Z

    remove useless import

commit 8e04f7fd840e245851240267c478bd469a910018
Author: wenlong.lwl <wenlong.lwl@alibaba-inc.com>
Date:   2016-08-16T02:46:31Z

    update job master interface definition and tests

commit 611079b3f174e9e30e1acf73634a822cd3cbb122
Author: wenlong.lwl <wenlong.lwl@alibaba-inc.com>
Date:   2016-08-16T02:57:37Z

    update comments of job master


> Introduce rpc protocols implemented by job manager
> --------------------------------------------------
>                 Key: FLINK-4375
>                 URL: https://issues.apache.org/jira/browse/FLINK-4375
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Distributed Coordination
>            Reporter: Wenlong Lyu
>            Assignee: Wenlong Lyu
>  job manager RPC server needs to  implement a job control protocol, resource user protocol,
task control protocol,
> 		1. job controller: cancelJob, suspendJob, etc.
> 		2. resource user: slotFailed(notify slot failure), slotAvailable(offer slot), etc.
> 		3. task controller: updateTaskState, updateResultPartitionInfo, etc.

This message was sent by Atlassian JIRA

View raw message