Support Questions

Find answers, ask questions, and share your expertise

NiFi 0.7.4 clustering issue

Explorer

I am trying to create a NiFi cluster using version 0.7.4 (I know its old but I am required to use it because the new version of NiFi 1.x does not support username and password login) but I keep receiving the below error:

WARN [main] o.a.nifi.controller.StandardFlowService Failed to connect to cluster due to: org.apache.nifi.cluster.protocol.ProtocolException: Failed to create socket due to: java.net.ConnectException: Connect timed out (Connection timed out).

The NCM and the nodes appear to be seeing each other but the heartbeat is failing.
When I access the UI of the NCM I receive this:

An unexpected error has occurred
Action was performed, but no nodes are connected.

Here are the nifi.properties cluster config on my NCM:

# cluster common properties (cluster manager and nodes must have same values) #
nifi.cluster.protocol.heartbeat.interval=5 sec
nifi.cluster.protocol.is.secure=true
nifi.cluster.protocol.socket.timeout=60 sec
nifi.cluster.protocol.connection.handshake.timeout=45 sec
# if multicast is used, then nifi.cluster.protocol.multicast.xxx properties must be configured #
nifi.cluster.protocol.use.multicast=false
nifi.cluster.protocol.multicast.address=
nifi.cluster.protocol.multicast.port=
nifi.cluster.protocol.multicast.service.broadcast.delay=500 ms
nifi.cluster.protocol.multicast.service.locator.attempts=3
nifi.cluster.protocol.multicast.service.locator.attempts.delay=1 sec

# cluster manager properties (only configure for cluster manager) #

nifi.cluster.is.manager=true
nifi.cluster.manager.address=192.168.1.233
nifi.cluster.manager.protocol.port=9555
nifi.cluster.manager.node.firewall.file=
nifi.cluster.manager.node.event.history.size=10
nifi.cluster.manager.node.api.connection.timeout=30 sec
nifi.cluster.manager.node.api.read.timeout=30 sec
nifi.cluster.manager.node.api.request.threads=10
nifi.cluster.manager.flow.retrieval.delay=5 sec
nifi.cluster.manager.protocol.threads=10
nifi.cluster.manager.safemode.duration=0 sec

Here are the nifi.properties cluster config on one of my nodes:

# cluster common properties (cluster manager and nodes must have same values) #
nifi.cluster.protocol.heartbeat.interval=5 sec
nifi.cluster.protocol.is.secure=true
nifi.cluster.protocol.socket.timeout=60 sec
nifi.cluster.protocol.connection.handshake.timeout=45 sec
# if multicast is used, then nifi.cluster.protocol.multicast.xxx properties must be configured #
nifi.cluster.protocol.use.multicast=false
nifi.cluster.protocol.multicast.address=
nifi.cluster.protocol.multicast.port=
nifi.cluster.protocol.multicast.service.broadcast.delay=500 ms
nifi.cluster.protocol.multicast.service.locator.attempts=3
nifi.cluster.protocol.multicast.service.locator.attempts.delay=1 sec

# cluster node properties (only configure for cluster nodes) #
nifi.cluster.is.node=true
nifi.cluster.node.address=192.168.1.234
nifi.cluster.node.protocol.port=9556
nifi.cluster.node.protocol.threads=2
# if multicast is not used, nifi.cluster.node.unicast.xxx must have same values as nifi.cluster.manager.xxx #
nifi.cluster.node.unicast.manager.address=192.168.1.233
nifi.cluster.node.unicast.manager.protocol.port=9555

I am also running this without using a zookeeper.

Is there a step by step guide on how to set up a cluster for the old version of NiFi?

Any help with this is appreciated.

1 REPLY 1

New Contributor

Hey,

 

I faced the same problem with version 0.7.2. I fixed it following this tutorial: https://www.youtube.com/watch?v=rvKTnRiEB9Q

 

I didn't use the hostnames as in the tutorial, I used 'localhost' everywhere instead

Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.