[ https://issues.apache.org/jira/browse/NIFI-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407649#comment-15407649 ]
ASF GitHub Bot commented on NIFI-2478: -------------------------------------- Github user markap14 commented on the issue: https://github.com/apache/nifi/pull/783 @ijokarumawak I verified the fix works & contrib-check looks good. +1 merged to master. Thanks for catching that! > Can not use the same Zookeeper by multiple NiFi clusters > -------------------------------------------------------- > > Key: NIFI-2478 > URL: https://issues.apache.org/jira/browse/NIFI-2478 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework > Affects Versions: 1.0.0 > Reporter: Koji Kawamura > Assignee: Mark Payne > Priority: Blocker > Fix For: 1.0.0 > > > I am trying to use the same external Zookeeper from two NiFi clusters. It's > expected this deployment is supported since there is > 'nifi.zookeeper.root.node' setting. > Set 'nifi.zookeeper.root.node' to '/nifi-cluster-1' for cluster-1, and > '/nifi-cluster-2' for cluster-2. > Cluster-1 started successfully. But Cluster-2 can't start with following > error: > {code} > 2016-08-04 07:45:58,787 INFO [main] o.a.c.f.imps.CuratorFrameworkImpl Starting > 2016-08-04 07:45:58,794 INFO [main-EventThread] > o.a.c.f.state.ConnectionStateManager State change: CONNECTED > 2016-08-04 07:45:58,795 INFO [main] o.a.n.c.c.node.CuratorNodeProtocolSender > No node has yet been elected Cluster Coordinator. Cannot establish connection > to cluster yet. > 2016-08-04 07:45:58,795 INFO [Curator-Framework-0] > o.a.c.f.imps.CuratorFrameworkImpl backgroundOperationsLoop exiting > 2016-08-04 07:45:58,797 WARN [main] o.a.nifi.controller.StandardFlowService > Failed to connect to cluster due to: > org.apache.nifi.cluster.protocol.ProtocolException: No node has yet been > elected Cluster Coordinator. Cannot establish connection to cluster yet. > org.apache.nifi.cluster.protocol.ProtocolException: No node has yet been > elected Cluster Coordinator. Cannot establish connection to cluster yet. > at > org.apache.nifi.cluster.coordination.node.CuratorNodeProtocolSender.getServiceAddress(CuratorNodeProtocolSender.java:108) > ~[nifi-framework-cluster-1.0.0-SNAPSHOT.jar:1.0.0-SNAPSHOT] > {code} > I looked at the Zookeeper znodes and found 'leaders' is not under configured > root node: > {code} > [zk: localhost:2181(CONNECTED) 17] ls / > [leaders, nifi-cluster-1, zookeeper] > {code} > Then, I looked at the source code, and found CuratorLeaderElectionManager has > following code: > {code} > final String rootPath = zkConfig.getRootPath(); > final String leaderPath = (rootPath.endsWith("/") ? "" : "/") + > "leaders/" + roleName; > {code} > It doesn't include rootPath while it should. -- This message was sent by Atlassian JIRA (v6.3.4#6332)