[
https://issues.apache.org/jira/browse/SAMZA-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jake Maes updated SAMZA-1360:
-----------------------------
Fix Version/s: (was: 0.14.0)
0.15.0
> 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
> Fix For: 0.15.0
>
>
> 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)
