[ https://issues.apache.org/jira/browse/SAMZA-1124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15899911#comment-15899911 ]
ASF GitHub Bot commented on SAMZA-1124: --------------------------------------- GitHub user sborya opened a pull request: https://github.com/apache/samza/pull/77 SAMZA-1124:Job coordinator with time out If a processor doesn't join the barrier for the TimeOut time - the barrier is cancelled. All the processor should unsubscribe from it. You can merge this pull request into a Git repository by running: $ git pull https://github.com/navina/samza JobCoordinatorWithTO Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/77.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 #77 ---- 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 fa2186b3443495017ec23011b64da52dbb9c9a82 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-07T23:30:11Z added ZkController commit 7a47f84a0117b2f66ea8c1c1a33a4a59100df856 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-07T23:46:38Z add main manual test commit 8e2d6c1a5bb2a0211419e98aa94c0948c78484bf Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-07T23:46:38Z add main manual test commit 737eb2fd29186237057e4b7ca572dec418b86fcd Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T00:10:31Z ZkTestUtils commit d20bacfd283823dbaa0853463c750dac30028354 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T00:10:31Z ZkTestUtils commit ff1550151ffdd9c31bf7c9f474ccf6a12ad183fc Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T00:21:51Z JavaJobConfig commit 63d8d604c932962c92d7f9033f128f1a8f094488 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T00:21:51Z JavaJobConfig commit d126b10b0700cb8a58bcf7ba4e9bc760ca57d894 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T00:25:03Z ScheduleAfterDebounceTime commit f904cd32efcdd7b5387bb0f815ebb02126138c41 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T00:25:03Z ScheduleAfterDebounceTime commit 7f17e26b3a8c13e148048f5d978e62edb981f8ae Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T00:10:31Z ZkTestUtils commit 6649c80ccd34804d1516ffe85c0ac0502ad581a3 Author: navina <nav...@apache.org> Date: 2017-02-08T00:51:33Z Fixing ZkUtils close(). No need to close underlying connection explicitly commit b3b27c650445de73bb5280e66d7688656e0ccb09 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T00:55:18Z Merge branch 'LeaderElector' into TestZkStreamProcessor commit 14db43d340422e1e6127d64fe3755480a7fe5a2a Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T01:04:50Z added TestZkStreamProcessor - main manual test commit 372829f5a4ac8a66445a3a8b5ce31e6ea49b0643 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T22:20:49Z Merge branch 'master' into JobCoordinator commit d0687b99324f7cdce560b138e656b142aa01b6a8 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T22:27:30Z Merge branch 'LeaderElector' into JobCoordinator commit 5f867c019eb4b63e017716444eb466589c5f209f Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T22:47:23Z added Apache license info commit 9c6b20a2db737910af60f64729915701c47a84d7 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-08T22:50:01Z added ZkListener 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 d32045bd89ea3a526df98bae0d8940df95f14c98 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-09T00:19:13Z Merge branch 'ScheduleAfterDebounceTime1' into JobCoordinator commit 48016130e07befaff42501a84c11da1e907c66a1 Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz> Date: 2017-02-09T01:44:17Z cleanup ---- > add a time out for ZkVersionUpgradeBarrier > ------------------------------------------ > > Key: SAMZA-1124 > URL: https://issues.apache.org/jira/browse/SAMZA-1124 > Project: Samza > Issue Type: Sub-task > Reporter: Boris Shkolnik > Assignee: Boris Shkolnik > Fix For: 0.13.0 > > > If a processor doesn't join during the TimeOut time, the barrier should be > cancelled - all the processors should unsubscribe from it. -- This message was sent by Atlassian JIRA (v6.3.15#6346)