Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

Nifi Cluster - Problem to elect a Cluster Coordinator

avatar
New Contributor

Hi everyone,

 

I am having some troubles with Nifi Cluster configuraition (version 1.16.2). Actually, the nodes are up and I can access them via https. But then:

nifi-result.PNG

 

When i checked the logs, the error was:

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

 

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

 

WARN [Heartbeat Monitor Thread-1] o.a.n.c.l.e.CuratorLeaderElectionManager Unable to determine leader for role 'Cluster Coordinator'; returning null

 

I tried a lot of possible solutions, but i still got the problem

 

My nifi.properties configuration:

nifi.cluster.is.node=true

nifi.cluster.node.address=node1

nifi.cluster.node.protocol.port=9999

nifi.cluster.node.protocol.max.threads=50

nifi.cluster.node.event.history.size=25

nifi.cluster.node.connection.timeout=5 sec

nifi.cluster.node.read.timeout=5 sec

nifi.cluster.node.max.concurrent.requests=100

nifi.cluster.firewall.file=

nifi.cluster.flow.election.max.wait.time=5 mins

nifi.cluster.flow.election.max.candidates=3

nifi.cluster.load.balance.host=

nifi.cluster.load.balance.port=6342

nifi.zookeeper.connect.string=node1:2181,node2:2181,node3:2181

 

My zookeeper.propeties configuration

server.1=0.0.0.0:2888:3888;2181

server.2=node2:2888:3888;2181

server.3=node3:2888:3888;2181

 

My stage-management.xml configurations:

    <cluster-provider>

        <id>zk-provider</id>

        <class>org.apache.nifi.controller.state.providers.zookeeper.ZooKeeperStateProvider</class>

        <property name="Connect String">node1:2181,node2:2181,node3:2181</property>

        <property name="Root Node">/nifi</property>

        <property name="Session Timeout">10 seconds</property>

        <property name="Access Control">Open</property>

    </cluster-provider>

 

1 REPLY 1

avatar

@_anjos 

Have you tried setting server.1=node1:2888:3888;2181