You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/03/01 23:05:45 UTC
[jira] [Commented] (SAMZA-1115) create ZK based JobCoordinator
[ https://issues.apache.org/jira/browse/SAMZA-1115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891257#comment-15891257 ]
ASF GitHub Bot commented on SAMZA-1115:
---------------------------------------
GitHub user sborya opened a pull request:
https://github.com/apache/samza/pull/70
SAMZA-1115:Job coordinator
Job coordinator to work with the ZooKeeper.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/navina/samza JobCoordinator
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/70.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 #70
----
commit 76b5167e856984d627a73f020d4ca1c7e9ae8750
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-01-23T21:16:49Z
added new line at then end
commit 37c2c8beddbf61325da80ea190e1f8e70d7c1bbc
Author: navina <na...@apache.org>
Date: 2017-01-23T21:16:49Z
Extracting files related to LeaderElection
commit aaaf24e2b159b21f28670171b027c2a69ea2737c
Author: navina <na...@apache.org>
Date: 2017-02-02T01:40:13Z
Adding EmbeddedZookeeper for testing
commit 317cf167ba9d5bd08e9ebe753892c2bd44befeb0
Author: navina <na...@apache.org>
Date: 2017-02-02T02:14:36Z
Adding tests for ZkKeyBuilder
commit 1734f8f905cafb2b1416422ac8809da30c3a848b
Author: navina <na...@apache.org>
Date: 2017-02-03T18:51:14Z
Adding tests for ZkUtils
commit 6dd6b8d8e891540ee75f0db5966afe5e7f599dd0
Author: navina <na...@apache.org>
Date: 2017-02-04T02:43:12Z
Adding tests for ZkLeaderElector
commit edda60d6b69fcbffae46975caa28b8091e877d1a
Author: navina <na...@apache.org>
Date: 2017-02-07T03:47:38Z
Removing an unintended change to the grouper
commit a0a74094f8366f0ee7898464fe75ae74c780cc84
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-07T21:56:05Z
Merge branch 'master' of https://github.com/navina/samza
commit fa2186b3443495017ec23011b64da52dbb9c9a82
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-07T23:30:11Z
added ZkController
commit 7a47f84a0117b2f66ea8c1c1a33a4a59100df856
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-07T23:46:38Z
add main manual test
commit 8e2d6c1a5bb2a0211419e98aa94c0948c78484bf
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-07T23:46:38Z
add main manual test
commit 737eb2fd29186237057e4b7ca572dec418b86fcd
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T00:10:31Z
ZkTestUtils
commit d20bacfd283823dbaa0853463c750dac30028354
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T00:10:31Z
ZkTestUtils
commit ff1550151ffdd9c31bf7c9f474ccf6a12ad183fc
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T00:21:51Z
JavaJobConfig
commit 63d8d604c932962c92d7f9033f128f1a8f094488
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T00:21:51Z
JavaJobConfig
commit d126b10b0700cb8a58bcf7ba4e9bc760ca57d894
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T00:25:03Z
ScheduleAfterDebounceTime
commit f904cd32efcdd7b5387bb0f815ebb02126138c41
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T00:25:03Z
ScheduleAfterDebounceTime
commit 7f17e26b3a8c13e148048f5d978e62edb981f8ae
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T00:10:31Z
ZkTestUtils
commit 6649c80ccd34804d1516ffe85c0ac0502ad581a3
Author: navina <na...@apache.org>
Date: 2017-02-08T00:51:33Z
Fixing ZkUtils close(). No need to close underlying connection explicitly
commit b3b27c650445de73bb5280e66d7688656e0ccb09
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T00:55:18Z
Merge branch 'LeaderElector' into TestZkStreamProcessor
commit 14db43d340422e1e6127d64fe3755480a7fe5a2a
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T01:04:50Z
added TestZkStreamProcessor - main manual test
commit 372829f5a4ac8a66445a3a8b5ce31e6ea49b0643
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T22:20:49Z
Merge branch 'master' into JobCoordinator
commit d0687b99324f7cdce560b138e656b142aa01b6a8
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T22:27:30Z
Merge branch 'LeaderElector' into JobCoordinator
commit 5f867c019eb4b63e017716444eb466589c5f209f
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T22:47:23Z
added Apache license info
commit 9c6b20a2db737910af60f64729915701c47a84d7
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T22:50:01Z
added ZkListener
commit d7a7ccbee29acf668c764b0bb4d32fbef0f0e471
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T22:50:56Z
Merge branch 'LeaderElector' into ScheduleAfterDebounceTime
commit ce8340986529faf0dd4e40aad8647f383e5891af
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T22:56:19Z
cleanup
commit 32f96b449243808c55e09f94f67602d5b233074d
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-08T23:10:10Z
added ScheduleAfterDebounce
commit d32045bd89ea3a526df98bae0d8940df95f14c98
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-09T00:19:13Z
Merge branch 'ScheduleAfterDebounceTime1' into JobCoordinator
commit 48016130e07befaff42501a84c11da1e907c66a1
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date: 2017-02-09T01:44:17Z
cleanup
----
> create ZK based JobCoordinator
> ------------------------------
>
> Key: SAMZA-1115
> URL: https://issues.apache.org/jira/browse/SAMZA-1115
> Project: Samza
> Issue Type: Sub-task
> Reporter: Boris Shkolnik
> Assignee: Boris Shkolnik
> Fix For: 0.13.0
>
>
> JobCooridantor that will work thru ZK for the job coordination.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)