[ 
https://issues.apache.org/jira/browse/SAMZA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Shanthoosh Venkataraman updated SAMZA-1583:
-------------------------------------------
    Description: 
Reading the processorId's of zookeeper ephemeral nodes is accomplished by the 
following two operations:

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.

  was:
Reading the processorId's of zookeeper ephemeral nodes are of following form:

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.


> 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
>
> Reading the processorId's of zookeeper ephemeral nodes is accomplished by the 
> following two operations:
> 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
(v7.6.3#76005)

Reply via email to