You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/05/31 00:56:04 UTC
[jira] [Commented] (APEXCORE-734) StramLocalCluster may not
terminate properly
[ https://issues.apache.org/jira/browse/APEXCORE-734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030448#comment-16030448 ]
ASF GitHub Bot commented on APEXCORE-734:
-----------------------------------------
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/532
APEXCORE-734 StramLocalCluster may not terminate properly
@PramodSSImmaneni @tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core APEXCORE-734
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/apex-core/pull/532.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 #532
----
commit 9aa23c35b0b6c4d60e50e2fc27ec147a1335e73d
Author: Vlad Rozov <vr...@apache.org>
Date: 2017-05-31T00:54:14Z
APEXCORE-734 StramLocalCluster may not terminate properly
----
> StramLocalCluster may not terminate properly
> --------------------------------------------
>
> Key: APEXCORE-734
> URL: https://issues.apache.org/jira/browse/APEXCORE-734
> Project: Apache Apex Core
> Issue Type: Improvement
> Reporter: Vlad Rozov
> Assignee: Vlad Rozov
>
> When StramLocalCluster is run asynchronously it may be shutdown during StramLocalCluster initialization leading to termination without performing necessary termination sequence. Runtime exception during the run may also lead to improper termination sequence. For example:
> {noformat}
> Exception in thread "master" java.lang.RuntimeException: java.lang.InterruptedException
> at com.datatorrent.bufferserver.server.Server.run(Server.java:154)
> at com.datatorrent.stram.StramLocalCluster.run(StramLocalCluster.java:474)
> at com.datatorrent.stram.StramLocalCluster.run(StramLocalCluster.java:459)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.InterruptedException
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1302)
> at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231)
> at com.datatorrent.bufferserver.server.Server.run(Server.java:152)
> ... 3 more
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)