GitHub user vjagadish opened a pull request: https://github.com/apache/samza/pull/525
SAMZA-1718: Simplify management of Zookeeper coordination state 1. Currently coordination related state is spread across several Zookeeper classes. There are also back-and-forth flows that exist between the ZkJobCoordinator, ZkControllerImpl, ZkControllerListener and ZkLeaderElector. This PR nukes un-necessary interfaces (and their implementation classes), simplifies state management and unifies state in the ZkJobCoordinator class. 2. Clearly defined life-cycle hooks on events: - Protocol validations happen once during the lifecycle of a StreamProcessor (instead of each new session) - New subscriptions to listeners happen at each a new Zk session You can merge this pull request into a Git repository by running: $ git pull https://github.com/vjagadish1989/samza zk-simplify Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/525.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 #525 ---- commit bc11712ad090e93b8dc767659fff628e8b9ccd8f Author: Jagadish <jvenkatraman@...> Date: 2018-05-04T20:59:01Z Fix NPE in ClusterResourceManager commit 6b05f8dd643d7b8c308412ea48bde80346b011e1 Author: Jagadish <jvenkatraman@...> Date: 2018-05-07T20:42:44Z Merge branch 'master' of https://github.com/apache/samza commit 8269d0bfaf50491d4756a9a35501c4980d8450e6 Author: Jagadish <jvenkatraman@...> Date: 2018-05-08T17:40:13Z Merge branch 'master' of https://github.com/apache/samza commit 1e8558aef3a145e20c15a9787726dfa312b61666 Author: Jagadish <jvenkatraman@...> Date: 2018-05-17T04:08:22Z Merge branch 'master' of https://github.com/apache/samza commit b3754ead688bafdc70df813e69b947fe20605d73 Author: Jagadish <jvenkatraman@...> Date: 2018-05-17T05:20:19Z Merge branch 'master' of https://github.com/apache/samza commit ef1d5bf6c432ebee135e5bc84032f8cf4e7314bf Author: Jagadish <jvenkatraman@...> Date: 2018-05-17T05:30:40Z Simplify management of Zookeeper coordination state ---- ---