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