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 2018/01/25 19:37:00 UTC

[jira] [Created] (SAMZA-1568) Handle ZkInterruptedException in zkclient.close.

Shanthoosh Venkataraman created SAMZA-1568:
----------------------------------------------

             Summary: Handle ZkInterruptedException in zkclient.close.
                 Key: SAMZA-1568
                 URL: https://issues.apache.org/jira/browse/SAMZA-1568
             Project: Samza
          Issue Type: Bug
            Reporter: Shanthoosh Venkataraman
            Assignee: Shanthoosh Venkataraman


When zookeeper session failures occur in a stream processor,   leaves the group(zkClient is closed) and joins the group again.

The last step in that shutdown sequence is zkClient.close(). In some scenarios, it throws the following exception, 
{code:java}
    org.I0Itec.zkclient.exception.ZkInterruptedException: java.lang.InterruptedException

    at org.I0Itec.zkclient.ZkClient.close(ZkClient.java:1278)

    at org.apache.samza.zk.ZkControllerImpl.stop(ZkControllerImpl.java:92)

    at org.apache.samza.zk.ZkJobCoordinator.stop(ZkJobCoordinator.java:141)
{code}
This is not handled currently, there by killing the stream processor itself. This exception causes the integration test to fail.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)