You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Navina Ramesh (JIRA)" <ji...@apache.org> on 2017/07/26 00:30:01 UTC
[jira] [Resolved] (SAMZA-1364) Unclean shutdown of
streamApplication in LocalApplicationRunner.kill(streamApplication)
[ https://issues.apache.org/jira/browse/SAMZA-1364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Navina Ramesh resolved SAMZA-1364.
----------------------------------
Resolution: Fixed
Issue resolved by pull request 246
[https://github.com/apache/samza/pull/246]
> 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
> Assignee: Shanthoosh Venkataraman
> Fix For: 0.13.1
>
>
> 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 in LocalApplicationRunner(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)