[jira] [Updated] (SAMZA-1360) Zookeeper session state handler for LocalApplicationRunner

["Jake Maes (JIRA)" <ji...@apache.org>]

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