Shanthoosh Venkataraman commented on SAMZA-1583:


One possible fix is to generate JobModel using available processors and not 
fail the leader during JobModel generation phase.

> Reading ephemeral node data throws ZkNoNodeExistsException.
> -----------------------------------------------------------
>                 Key: SAMZA-1583
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1583
>             Project: Samza
>          Issue Type: Bug
>            Reporter: Shanthoosh Venkataraman
>            Assignee: Shanthoosh Venkataraman
>            Priority: Major
> Leader reads the processorId's of zookeeper ephemeral nodes through the 
> following two operations to generate JobModel:
> A. ephemeralZkNodes = Get the list of ephemeral zookeeper nodes.
> B. For each zkNode in ephemeralZkNodes:
>            fetch data of the zkNode.
> The zkNodes returned by the operation A, may no longer be available when 
> fetch data remote call was made. This will cause zkClient to throw 
> ZkNoNodeExistsException. This exception is unhandled currently, there by 
> failing the leader.

This message was sent by Atlassian JIRA

Reply via email to