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)
