[
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 <[email protected]>
Date: 2016-08-12T11:40:17Z
add Job Master RPC protocols
commit e6c463e1c55cb9269fa549ca6abd439707c833f5
Author: wenlong.lwl <[email protected]>
Date: 2016-08-15T02:42:42Z
Merge branch 'flip-6' of github.com:apache/flink into flip-6
commit 573bf635d8912610b9cbcc58d3081a899c894999
Author: wenlong.lwl <[email protected]>
Date: 2016-08-15T06:00:33Z
do some refactor on job master gateway interface
commit fe29f628f02ed01489e3051de63207b8dd6c53d0
Author: wenlong.lwl <[email protected]>
Date: 2016-08-15T07:14:40Z
remove useless import
commit 8e04f7fd840e245851240267c478bd469a910018
Author: wenlong.lwl <[email protected]>
Date: 2016-08-16T02:46:31Z
update job master interface definition and tests
commit 611079b3f174e9e30e1acf73634a822cd3cbb122
Author: wenlong.lwl <[email protected]>
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)
