[
https://issues.apache.org/jira/browse/APEXCORE-734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16088239#comment-16088239
]
ASF GitHub Bot commented on APEXCORE-734:
-----------------------------------------
PramodSSImmaneni commented on issue #532: APEXCORE-734 StramLocalCluster may
not terminate properly
URL: https://github.com/apache/apex-core/pull/532#issuecomment-315485744
Can you rebase
----------------------------------------------------------------
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:
[email protected]
> 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)
