Shanthoosh Venkataraman created SAMZA-1360:
----------------------------------------------
Summary: Zookeeper session state handler for LocalApplicationRunner
Key: SAMZA-1360
URL: https://issues.apache.org/jira/browse/SAMZA-1360
Project: Samza
Issue Type: Improvement
Reporter: Shanthoosh Venkataraman
Priority: Minor
When zookeeper client reestablishes connection with zookeeper server, it should
not receive notifications/events for previous session. Acting on zookeeper
events without distinction if they belong to current session leads to incorrect
behavior. However, it's discovered from testing that this contract isn't
honored(zookeeper client receives events from earlier sessions).
SAMZA-1336 introduces sessionListeners(which gets triggered onNewSession,
newEvent) for ZkJobCoordinator handling stale events. Similar mechanism should
be followed for ZkCoordinationService used by LocalApplicationRunner for leader
election.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
