Vlad Rozov created APEXCORE-734:
-----------------------------------
Summary: 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)
