[
https://issues.apache.org/jira/browse/APEXCORE-734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16089146#comment-16089146
]
ASF GitHub Bot commented on APEXCORE-734:
-----------------------------------------
PramodSSImmaneni closed pull request #532: APEXCORE-734 StramLocalCluster may
not terminate properly
URL: https://github.com/apache/apex-core/pull/532
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> 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.4.14#64029)
