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 2017/02/13 09:22:42 UTC
[jira] [Commented] (FLINK-5074) Implement a RunningJobRegistry
based on Zookeeper
[ https://issues.apache.org/jira/browse/FLINK-5074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863374#comment-15863374 ]
ASF GitHub Bot commented on FLINK-5074:
---------------------------------------
GitHub user shuai-xu reopened a pull request:
https://github.com/apache/flink/pull/2903
[FLINK-5074] [runtime] add a zookeeper based running job registry
This pr is for jira #[5074](https://issues.apache.org/jira/browse/FLINK-5074).
Implement a zookeeper based running job registry for flip-6. It will write the running job info to zookeeper and support querying job status.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/shuai-xu/flink jira-5074
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2903.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 #2903
----
commit 18d9e17f10cf98d9fe351da181cae57b52957f6f
Author: shuai.xus <sh...@alibaba-inc.com>
Date: 2016-11-30T08:05:55Z
[FLINK-5704] [runtime] add a zookeeper based running job registry
commit 5a623063e2f9a39e6e0eb32319faa7e9d564cf3d
Author: shuai.xus <sh...@alibaba-inc.com>
Date: 2016-12-01T07:27:11Z
[FLINK-5074] [runtime] HighAvailabilityServicesUtils support new ZookeeperHaServices
commit 2f42ec657eb69197ef5280c114d486ccd1271c44
Author: shuai.xus <sh...@alibaba-inc.com>
Date: 2016-12-05T06:12:39Z
[FLINK-5074] [runtime] fix get zk path bug and add unittest
commit 0fa9a8d7e4d31451f72177f93e3fba3ca5ad3593
Author: shuai.xus <sh...@alibaba-inc.com>
Date: 2016-12-21T09:44:44Z
[FLINK-5074] [runtime] add throws Exception to before and after
----
> Implement a RunningJobRegistry based on Zookeeper
> --------------------------------------------------
>
> Key: FLINK-5074
> URL: https://issues.apache.org/jira/browse/FLINK-5074
> Project: Flink
> Issue Type: Task
> Components: Cluster Management
> Reporter: shuai.xu
> Assignee: shuai.xu
> Labels: flip-6
>
> For flip-6, it has implemented the ZookeeperHaServices, but ZookeeperHaServices does not support getRunningJobsRegistry. So need to implement a ZK based running job registry.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)