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/02/13 00:13:00 UTC

[jira] [Commented] (SAMZA-1583) Reading ephemeral node data throws ZkNoNodeExistsException.

    [ https://issues.apache.org/jira/browse/SAMZA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16361626#comment-16361626 ] 

Shanthoosh Venkataraman commented on SAMZA-1583:
------------------------------------------------

[~boryas]

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
(v7.6.3#76005)