You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Boris Shkolnik (JIRA)" <ji...@apache.org> on 2017/03/07 18:30:38 UTC

[jira] [Created] (SAMZA-1124) add a time out for ZkVersionUpgradeBarrier

Boris Shkolnik created SAMZA-1124:
-------------------------------------

             Summary: add a time out for ZkVersionUpgradeBarrier
                 Key: SAMZA-1124
                 URL: https://issues.apache.org/jira/browse/SAMZA-1124
             Project: Samza
          Issue Type: Sub-task
            Reporter: Boris Shkolnik
            Assignee: Boris Shkolnik


If a processor doesn't join during the TimeOut time, the barrier should be cancelled - all the processors should unsubscribe from it.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)