You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/07/19 20:30:00 UTC
[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16093743#comment-16093743 ]
Shanthoosh Venkataraman commented on SAMZA-1364:
------------------------------------------------
[~navina] [~boryas]
Solution:
Handle exceptions in zkClient.close() in LocalApplicationRunner and in other places.
> 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(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)