Bharath Kumarasubramanian created SAMZA-1385:

             Summary: Coordination utils in LocalApplicationRunner uses same Zk 
path as ZkJobCoordinatorFactory for leader election
                 Key: SAMZA-1385
             Project: Samza
          Issue Type: Bug
            Reporter: Bharath Kumarasubramanian
            Assignee: Bharath Kumarasubramanian

In case of applications which involves creating intermediate stream, we perform 
the leader election twice. once for coordination for stream creation and 
another for job coordination.

We currently use the same zookeeper path for both of these and this results in 
two nodes for the same processor in zookeeper. As a result, the process goes 
into listener mode and stuck in job model generation phase.

This message was sent by Atlassian JIRA

Reply via email to