You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/28 19:04:00 UTC

[jira] [Commented] (SAMZA-1372) Change Latch Interface to Lock Interface for Samza Standalone with ZK

    [ https://issues.apache.org/jira/browse/SAMZA-1372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417934#comment-16417934 ] 

ASF GitHub Bot commented on SAMZA-1372:
---------------------------------------

Github user PawasChhokra closed the pull request at:

    https://github.com/apache/samza/pull/264


> Change Latch Interface to Lock Interface for Samza Standalone with ZK
> ---------------------------------------------------------------------
>
>                 Key: SAMZA-1372
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1372
>             Project: Samza
>          Issue Type: Improvement
>            Reporter: Pawas Chhokra
>            Assignee: Pawas Chhokra
>            Priority: Major
>
> The current implementation of 'creating intermediate streams' depends on leader election, followed by the leader creating the intermediate streams. We have removed this dependency on leader election and changed the Latch interface to a generic Lock interface. Following this, any processor that acquires the lock can create the intermediate streams, irrespective of whether it is the leader or not. It releases the lock after successful creation of the streams.  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)