[
https://issues.apache.org/jira/browse/SAMZA-1385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142300#comment-16142300
]
ASF GitHub Bot commented on SAMZA-1385:
---------------------------------------
GitHub user sborya opened a pull request:
https://github.com/apache/samza/pull/284
SAMZA-1385: Coordination utils factory with distributed lock
this PR includes some changes from another PR. I will re-merge it again,
after the other PR is in.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/sborya/samza
CoordinationUtilsFactory_withDistributedLock
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/284.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 #284
----
commit 9de7539727e227c92f67be4ae0d9de4a8a1ae26c
Author: Boris Shkolnik <[email protected]>
Date: 2017-08-22T17:36:18Z
created the factory
commit b6363ccfe6bb458047df11fff3e012e06cdd79b8
Author: Boris Shkolnik <[email protected]>
Date: 2017-08-22T18:42:56Z
removed reset, added close() per interface
commit 1ac7ae9d260380d61afa7fea7a12d1ae110dc334
Author: Boris Shkolnik <[email protected]>
Date: 2017-08-22T18:47:18Z
use getName() for class name
commit 14e64e95443113669563e447cb6e3b86749615d4
Author: Boris Shkolnik <[email protected]>
Date: 2017-08-23T00:23:11Z
update 4.8.1
commit b15e0fce7a336b3663529e3e9e7539f85f6afe2c
Author: Boris Shkolnik <[email protected]>
Date: 2017-08-23T00:35:50Z
update 4.8.1
commit ec075bfd2731e429598c20d357cf6c9550ea51f1
Author: Boris Shkolnik <[email protected]>
Date: 2017-08-23T18:02:46Z
added Distributed lock
commit 71cafa96e7abede5d76e8a907c2354bcdaff33a0
Author: Boris Shkolnik <[email protected]>
Date: 2017-08-24T01:59:52Z
added locks
commit 436519b0121136b1edb2c3b8fa6e4784d45244e3
Author: Boris Shkolnik <[email protected]>
Date: 2017-08-24T22:32:42Z
abstract
commit e0f22f09f4de6528a30cd1541974314e48dec14f
Author: Boris Shkolnik <[email protected]>
Date: 2017-08-25T21:04:09Z
Merge branch 'master' into CoordinationUtilsFactory_withDistributedLock
commit 52f4d3d13e872ba86894f7fe5161067458cbb5d1
Author: Boris Shkolnik <[email protected]>
Date: 2017-08-25T21:04:53Z
merge
----
> Fix coordination issues during stream creation in LocalApplicationRunner
> ------------------------------------------------------------------------
>
> Key: SAMZA-1385
> URL: https://issues.apache.org/jira/browse/SAMZA-1385
> Project: Samza
> Issue Type: Bug
> Reporter: Bharath Kumarasubramanian
> Assignee: Bharath Kumarasubramanian
> Fix For: 0.13.1
>
>
> Bug fixes related to coordination logic around stream creation.
> In case of applications that involve creating intermediate stream, a single
> process waits for itself to become a leader during job coordination phase if
> it has already acquired leadership during stream creation phase. The reason
> for this starvation is due to the fact that both these leader election use
> the same zookeeper node. We need to use separate nodes for leader election
> for job model creation & stream creation.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
