i  have been unable to get a unsecured cluster up and running following the instructions provided on the Apache nifi web site.   ... View more

Hello Matt -   I've spent hours trying to a unsecured cluster set up and running.  Regarding your suggestions: 1.  I confirmed that the nodes could resolve each other by pinging amongst the 3 nodes.  2.  I was not able to get ports free.  I kept receiving "connection refused by foreign host".  I was unable to resolve this. 3. I confirmed that the firewall in my ubuntu 22.40 clients was not active.   I am very disappointed that following the instructions on the Apache nifi site I am unable to get an unsecured cluster up and running in short order.         ... View more

Matt -   I will be able to work on this this pm. when I get home.  I will update the ticket. Thanks again for your terrific help!  I feel like I'm getting close 🙂   VR,   Dave ... View more

Thanks so much Matt!  I will definitely follow your guidance and update!     ... View more

I also created the following files (as indicated in the instructions:   a file named myid in state/zookeeper (with a value of 1) in nificlient1 a file named myid in state/zookeeper (with a value of 2) in nificient2 a file named myid in state/zookeeper (with a value of 3) in nificlient3 ... View more

Here is the repeating set of message from the nifi-app.log 2023-01-07 10:25:52,851 WARN [main] o.a.n.c.l.e.CuratorLeaderElectionManager Unable to determine leader for role 'Cluster Coordinator'; returning null org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /nifi/leaders/Cluster Coordinator at org.apache.zookeeper.KeeperException.create(KeeperException.java:102) at org.apache.zookeeper.KeeperException.create(KeeperException.java:54) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:2480) at org.apache.curator.framework.imps.GetChildrenBuilderImpl$3.call(GetChildrenBuilderImpl.java:242) at org.apache.curator.framework.imps.GetChildrenBuilderImpl$3.call(GetChildrenBuilderImpl.java:231) at org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:93) at org.apache.curator.framework.imps.GetChildrenBuilderImpl.pathInForeground(GetChildrenBuilderImpl.java:228) at org.apache.curator.framework.imps.GetChildrenBuilderImpl.forPath(GetChildrenBuilderImpl.java:219) at org.apache.curator.framework.imps.GetChildrenBuilderImpl.forPath(GetChildrenBuilderImpl.java:41) at org.apache.curator.framework.recipes.locks.LockInternals.getSortedChildren(LockInternals.java:154) at org.apache.curator.framework.recipes.locks.LockInternals.getParticipantNodes(LockInternals.java:134) at org.apache.curator.framework.recipes.locks.InterProcessMutex.getParticipantNodes(InterProcessMutex.java:170) at org.apache.curator.framework.recipes.leader.LeaderSelector.getLeader(LeaderSelector.java:337) at org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager.getLeader(CuratorLeaderElectionManager.java:281) at org.apache.nifi.cluster.coordination.node.LeaderElectionNodeProtocolSender.getServiceAddress(LeaderElectionNodeProtocolSender.java:46) at org.apache.nifi.cluster.protocol.AbstractNodeProtocolSender.requestConnection(AbstractNodeProtocolSender.java:64) at org.apache.nifi.cluster.protocol.impl.NodeProtocolSenderListener.requestConnection(NodeProtocolSenderListener.java:89) at org.apache.nifi.controller.StandardFlowService.connect(StandardFlowService.java:928) at org.apache.nifi.controller.StandardFlowService.load(StandardFlowService.java:476) at org.apache.nifi.web.server.JettyServer.start(JettyServer.java:892) at org.apache.nifi.NiFi.<init>(NiFi.java:172) at org.apache.nifi.NiFi.<init>(NiFi.java:83) at org.apache.nifi.NiFi.main(NiFi.java:332) ... View more

Hello Matt - I let nifi start for over 12 hours and it was still in an unresolved state. Here are the items I changed in each of the respective files from each of the 3 nodes: Zookeeper.properties   server.1=nificlient1:2888:3888;2181 server.2=nificlient2:2888:3888;2181 server.3=nificlient3:2888:3888;2181   nifi.properties   nifi.state.management.embedded.zookeeper.start=true nifi.cluster.protocol.is.secure=true nifi.cluster.is.node=true nifi.cluster.node.address=nificlient1 nifi.cluster.node.protocol.port=9991 nifi.cluster.flow.election.max.candidates=3 nifi.zookeeper.connect.string=nificlient1:2181,nificlient2:2181,nificlient3:2181   state-management.xml   <cluster-provider>         <id>zk-provider</id>         <class>org.apache.nifi.controller.state.providers.zookeeper.ZooKeeperStateProvider</class>         <property name="Connect String">nificlient1:2181,nificlient2:2181,nificlient3:2181</property>         <property name="Root Node">/nifi</property>         <property name="Session Timeout">10 seconds</property>         <property name="Access Control">Open</property>     </cluster-provider> Any additional suggestions/recommendations would be tremendously appreciated.   VR,   Dave ... View more

Hello Vidya -   I will have an opportunity to work with this this weekend and I certainly will mark the appropriate reply as soon as I have had an opportunity to follow Matt's guidance.  Thanks so much Vidya and Matt!   VR,   Dave ... View more

Thanks so much Matt!  I will follow your guidance!     ... View more

Hello Matt... Thank you for the substantive reply. I did make the change you indicated at the top of your response and am not only receiving the following errors...I am so close! 2023-01-04 21:42:19,158 WARN [main] o.a.nifi.controller.StandardFlowService There is currently no Cluster Coordinator. This often happens upon restart of NiFi when running an embedded ZooKeeper. Will register this node to become the active Cluster Coordinator and will attempt to connect to cluster again 2023-01-04 21:42:19,158 INFO [main] o.a.n.c.l.e.CuratorLeaderElectionManager CuratorLeaderElectionManager[stopped=false] Attempted to register Leader Election for role 'Cluster Coordinator' but this role is already registered   ... View more