[jira] [Created] (SAMZA-1364) Unclean shutdown of streamApplication in LocalApplicationRunner.kill(streamApplication)

["Shanthoosh Venkataraman (JIRA)" <ji...@apache.org>]

Shanthoosh Venkataraman created SAMZA-1364:
----------------------------------------------

             Summary: Unclean shutdown of streamApplication in LocalApplicationRunner.kill(streamApplication) 
                 Key: SAMZA-1364
                 URL: https://issues.apache.org/jira/browse/SAMZA-1364
             Project: Samza
          Issue Type: Bug
            Reporter: Shanthoosh Venkataraman


In some cases LocalAppRunner.waitForFinish indefinitely blocks after LocalApplicationRunner.kill. Last step in LocalAppRunner.kill(streamApp) is zkClient.close()[zkClient belongs to ZkCoordinationService].

ApplicationRunner.kill triggers listeners chain & in final listener zkclient.close throws ZkInterruptedException (RuntimeException) & it's swallowed in listeners preventing shutdownLatch update(required for proper shutdown).


Exception log:


{code:java}
org.I0Itec.zkclient.exception.ZkInterruptedException: java.lang.InterruptedException
    at org.I0Itec.zkclient.ZkClient.close(ZkClient.java:1277)
    at org.apache.samza.zk.ZkUtils.close(ZkUtils.java:296)
    at org.apache.samza.zk.ZkCoordinationUtils.reset(ZkCoordinationUtils.java:47)

{code}





--
This message was sent by Atlassian JIRA
(v6.4.14#64029)