apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Vlad Rozov (JIRA)" <j...@apache.org>
Subject [jira] [Created] (APEXCORE-734) StramLocalCluster may not terminate properly
Date Wed, 31 May 2017 00:54:04 GMT
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)

Mime
View raw message