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/16 03:49:20 UTC
[jira] [Commented] (FLINK-4375) Introduce rpc protocols implemented
by job manager
[ 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:
https://github.com/apache/flink/pull/2375
[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:
https://github.com/apache/flink/pull/2375.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 #2375
----
commit b9fd92697478ffc81a9f6ee7b3b14edfab5a02f2
Author: wenlong.lwl <we...@alibaba-inc.com>
Date: 2016-08-12T11:40:17Z
add Job Master RPC protocols
commit e6c463e1c55cb9269fa549ca6abd439707c833f5
Author: wenlong.lwl <we...@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 <we...@alibaba-inc.com>
Date: 2016-08-15T06:00:33Z
do some refactor on job master gateway interface
commit fe29f628f02ed01489e3051de63207b8dd6c53d0
Author: wenlong.lwl <we...@alibaba-inc.com>
Date: 2016-08-15T07:14:40Z
remove useless import
commit 8e04f7fd840e245851240267c478bd469a910018
Author: wenlong.lwl <we...@alibaba-inc.com>
Date: 2016-08-16T02:46:31Z
update job master interface definition and tests
commit 611079b3f174e9e30e1acf73634a822cd3cbb122
Author: wenlong.lwl <we...@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
(v6.3.4#6332)