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 2017/08/09 18:58: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=16120466#comment-16120466 ]
ASF GitHub Bot commented on SAMZA-1372:
---------------------------------------
GitHub user PawasChhokra opened a pull request:
https://github.com/apache/samza/pull/264
SAMZA-1372: Change Latch Interface to Lock Interface for Samza Standalone with ZK
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/PawasChhokra/samza ZkLock
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/264.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #264
----
commit f1881b1e65d1ffb67c9d669192c6e0d5fe90a079
Author: PawasChhokra <pa...@gmail.com>
Date: 2017-08-08T17:33:26Z
Add lock
commit eddeb45addfef458e8b7875b4d8703191c2a74c5
Author: PawasChhokra <pa...@gmail.com>
Date: 2017-08-09T18:54:08Z
Add create streams with lock
----
> 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
>
> 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
(v6.4.14#64029)