GitHub user zhuhaifengleon opened a pull request: https://github.com/apache/flink/pull/2520
Jira 4530 This PR implement a more generalized and reusable RPC connection components. It encapsulates the RPC connection management and pulling out the strong dependency on the 'TaskExecutor' and 'JobMaster' and the `ResourceManagerGateway`. The connection from JobMaster to ResourceManager can be implemented based on the RPC connection component, as well as the connection from TaskExecute to ResourceManager. The PR refactor the TaskExecutorToResourceManagerConnection, while adding JobMasterToResourceManagerConnection. You can merge this pull request into a Git repository by running: $ git pull https://github.com/zhuhaifengleon/flink jira-4530 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/2520.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 #2520 ---- commit 086f8712efdd416c94954485aaa4b541a9001857 Author: zhuhaifengleon <zhu.haifeng.l...@gmail.com> Date: 2016-09-20T06:15:52Z [FLINK-4530] Generalize TaskExecutorToResourceManagerConnection to be reusable commit 22a96a5ede94167cdf9e160f9642e2dad560beb6 Author: zhuhaifengleon <zhu.haifeng.l...@gmail.com> Date: 2016-09-20T06:15:52Z [FLINK-4530] Generalize TaskExecutorToResourceManagerConnection to be reusable commit e515f057dc679a8c4467efdb53361b5dc3aa34be Author: zhuhaifengleon <zhu.haifeng.l...@gmail.com> Date: 2016-09-20T09:03:12Z [FLINK-4530] Generalize TaskExecutorToResourceManagerConnection to be reusable commit 85a5eccef3cc2907c37076fed20be583cd388d49 Author: zhuhaifengleon <zhu.haifeng.l...@gmail.com> Date: 2016-09-20T13:37:56Z [FLINK-4530] Generalize TaskExecutorToResourceManagerConnection to be reusable ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---