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

Posted to commits@samza.apache.org by "Jagadish (JIRA)" <ji...@apache.org> on 2017/07/22 00:37:00 UTC

[jira] [Updated] (SAMZA-1368) make sure that a new job model will be generated if zk barrier times out.

     [ https://issues.apache.org/jira/browse/SAMZA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jagadish updated SAMZA-1368:
----------------------------
    Fix Version/s: 0.13.1

> make sure that a new job model will be generated if zk barrier times out.
> -------------------------------------------------------------------------
>
>                 Key: SAMZA-1368
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1368
>             Project: Samza
>          Issue Type: Bug
>            Reporter: Boris Shkolnik
>            Assignee: Boris Shkolnik
>             Fix For: 0.13.1
>
>
> When barrier times out, participants do nothing. We rely on fact that the timeout happened because of a participant leaving. But if it timed out for any other reason, we may end up in a stuck state. 
> So to cover this unknown we will add an explicit call to doOnProcessorChange for the leader.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)