GitHub user sborya opened a pull request:

    https://github.com/apache/samza/pull/61

    SAMZA-1103: ZkBarrier

    SAMZA-1103: Barrier for JobModel upgrades. When all the processors got 
notification about the new JobModel, only after that they can start using the 
new model.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/navina/samza ZkBarrier

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/samza/pull/61.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 #61
    
----
commit 76b5167e856984d627a73f020d4ca1c7e9ae8750
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-01-23T21:16:49Z

    added new line at then end

commit 37c2c8beddbf61325da80ea190e1f8e70d7c1bbc
Author: navina <nav...@apache.org>
Date:   2017-01-23T21:16:49Z

    Extracting files related to LeaderElection

commit aaaf24e2b159b21f28670171b027c2a69ea2737c
Author: navina <nav...@apache.org>
Date:   2017-02-02T01:40:13Z

    Adding EmbeddedZookeeper for testing

commit 317cf167ba9d5bd08e9ebe753892c2bd44befeb0
Author: navina <nav...@apache.org>
Date:   2017-02-02T02:14:36Z

    Adding tests for ZkKeyBuilder

commit 1734f8f905cafb2b1416422ac8809da30c3a848b
Author: navina <nav...@apache.org>
Date:   2017-02-03T18:51:14Z

    Adding tests for ZkUtils

commit 6dd6b8d8e891540ee75f0db5966afe5e7f599dd0
Author: navina <nav...@apache.org>
Date:   2017-02-04T02:43:12Z

    Adding tests for ZkLeaderElector

commit edda60d6b69fcbffae46975caa28b8091e877d1a
Author: navina <nav...@apache.org>
Date:   2017-02-07T03:47:38Z

    Removing an unintended change to the grouper

commit a0a74094f8366f0ee7898464fe75ae74c780cc84
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-07T21:56:05Z

    Merge branch 'master' of https://github.com/navina/samza

commit d126b10b0700cb8a58bcf7ba4e9bc760ca57d894
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-08T00:25:03Z

    ScheduleAfterDebounceTime

commit 6649c80ccd34804d1516ffe85c0ac0502ad581a3
Author: navina <nav...@apache.org>
Date:   2017-02-08T00:51:33Z

    Fixing ZkUtils close(). No need to close underlying connection explicitly

commit d7a7ccbee29acf668c764b0bb4d32fbef0f0e471
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-08T22:50:56Z

    Merge branch 'LeaderElector' into ScheduleAfterDebounceTime

commit ce8340986529faf0dd4e40aad8647f383e5891af
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-08T22:56:19Z

    cleanup

commit 32f96b449243808c55e09f94f67602d5b233074d
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-08T23:10:10Z

    added ScheduleAfterDebounce

commit 3df0def4bc50d6fcbd9b086b902ddecd32b9b039
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-09T01:49:52Z

    ZkControllerImpl

commit f0cae7bf62d4f204c26613f741fb27b08995388e
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-09T01:49:55Z

    Merge branch 'LeaderElector' into ZkController

commit c9b3fe4c540e093e433b013cd278f3a35d3c5d1f
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-09T01:50:08Z

    Merge branch 'ScheduleAfterDebounceTime' into ZkController

commit efc4d03e4c19862b20075cd872235c233203d959
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-09T02:29:25Z

    ZkController

commit b28ba1424735d37b72f8034e3aba7d6cb4c05e73
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-09T18:11:13Z

    ZkBarrier

commit cfdb4c77dff5a74a3797c85f033233cd65b61ec3
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-09T18:20:31Z

    Merge branch 'ZkController' into ZkBarrier

commit dc26bd22ca37b989db759c703fd88a6258772c65
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-09T19:08:11Z

    added BarrierForVersionUpgrade

commit 358ae6bbc7fb139b952ae9b0ec8821f8ec7e81b2
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-13T18:42:11Z

    Added test and addressed review comments

commit eaf04bb726508ab9e18509cda03613e350d0b2b7
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-13T18:49:07Z

    added more comments

commit ba583d63ae04ce041e2cc8615276a59ae97b1eb3
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-13T22:54:58Z

    merge

commit ad9108af5e0e47b31240d2d06738d76ea12a1d1a
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-13T22:57:04Z

    merge with ScheduleAfterDebounceTime

commit fabddc930289e58017c6546cbf95652e32abb2cd
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-13T23:01:15Z

    merge

commit 3412ed46d2e602346e5a3f76605c50b9ec2ae94c
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-14T17:59:58Z

    Renamed ZkListener to ZkControllerListener

commit b473a6e6e148b57983d6b50db41a363a1226dba0
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-14T18:00:46Z

    Added the new file ZkControllerListener.java

commit 592e9bbcbfd8ff4be84f6472f15624370d49b0b3
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-14T18:35:04Z

    added missing functionality for ZkControllerImpl into zkUtils and 
zkKeyBuilder

commit c9bb475391bac82f8fb226599fce46d16cdb09d2
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-14T23:33:03Z

    added tests for ZkUtils

commit 7ebe9a60180c9a9068214be5d19f228291702cc5
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Date:   2017-02-16T02:38:34Z

    check style

----


---
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.
---

Reply via email to