You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/07/12 17:16:00 UTC

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

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)