You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Emanuele Costantini (Jira)" <ji...@apache.org> on 2022/03/23 16:57:00 UTC

[jira] [Updated] (NIFI-9828) Apache NiFi 1.15.3 - Load balancing error on one cluster node due to java.net.UnknownHostException: null

     [ https://issues.apache.org/jira/browse/NIFI-9828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Emanuele Costantini updated NIFI-9828:
--------------------------------------
    Description: 
I have a 11 nodes NiFi cluster. Each node can correctly communicate to each other.
However when the other nodes try to connect to a node 021 for load balancing, the following error occurs:

 
{code:java}
ERROR [Load-Balanced Client Thread-8] o.a.n.c.q.c.c.a.n.NioAsyncLoadBalanceClient Unable to connect to as021dos.intranet.fw:18090 for load balancing
java.net.UnknownHostException: null
at sun.nio.ch.Net.translateException(Net.java:154)
at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:127)
at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:80)
at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.createChannel(NioAsyncLoadBalanceClient.java:496)
at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.establishConnection(NioAsyncLoadBalanceClient.java:439)
at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.communicate(NioAsyncLoadBalanceClient.java:234)
at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClientTask.run(NioAsyncLoadBalanceClientTask.java:81)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748){code}
The error can be seen on all nodes and only towards the node 021.

 

Load balancing properties are the following on ALL nodes (actual ip address instead of "ipv4_address"):
{code:java}
nifi.cluster.load.balance.host=ipv4_address
nifi.cluster.load.balance.port=6342
nifi.cluster.load.balance.connections.per.node=4
nifi.cluster.load.balance.max.thread.count=8
nifi.cluster.load.balance.comms.timeout=30 sec{code}
While 18090, which is the port appearing in the error, is the HTTPS port.

Any idea on why does the error raise? And why does it appear just towards one node?

Thanks

  was:
I have a 11 nodes NiFi cluster. Each node can correctly communicate to each other.
However when the other nodes try to connect to a node 021 for load balancing, the following error occurs (x put instead of real name):

 
{code:java}
ERROR [Load-Balanced Client Thread-8] o.a.n.c.q.c.c.a.n.NioAsyncLoadBalanceClient Unable to connect to as021dos.intranet.fw:18090 for load balancing
java.net.UnknownHostException: null
at sun.nio.ch.Net.translateException(Net.java:154)
at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:127)
at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:80)
at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.createChannel(NioAsyncLoadBalanceClient.java:496)
at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.establishConnection(NioAsyncLoadBalanceClient.java:439)
at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.communicate(NioAsyncLoadBalanceClient.java:234)
at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClientTask.run(NioAsyncLoadBalanceClientTask.java:81)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748){code}
The error can be seen on all nodes and only towards the node 021.

 

Load balancing properties are the following on ALL nodes (actual ip address instead of "ipv4_address"):
{code:java}
nifi.cluster.load.balance.host=ipv4_address
nifi.cluster.load.balance.port=6342
nifi.cluster.load.balance.connections.per.node=4
nifi.cluster.load.balance.max.thread.count=8
nifi.cluster.load.balance.comms.timeout=30 sec{code}
While 18090, which is the port appearing in the error, is the HTTPS port.

Any idea on why does the error raise? And why does it appear just towards one node?

Thanks


> Apache NiFi 1.15.3 - Load balancing error on one cluster node due to java.net.UnknownHostException: null
> --------------------------------------------------------------------------------------------------------
>
>                 Key: NIFI-9828
>                 URL: https://issues.apache.org/jira/browse/NIFI-9828
>             Project: Apache NiFi
>          Issue Type: Bug
>    Affects Versions: 1.15.3
>            Reporter: Emanuele Costantini
>            Priority: Major
>
> I have a 11 nodes NiFi cluster. Each node can correctly communicate to each other.
> However when the other nodes try to connect to a node 021 for load balancing, the following error occurs:
>  
> {code:java}
> ERROR [Load-Balanced Client Thread-8] o.a.n.c.q.c.c.a.n.NioAsyncLoadBalanceClient Unable to connect to as021dos.intranet.fw:18090 for load balancing
> java.net.UnknownHostException: null
> at sun.nio.ch.Net.translateException(Net.java:154)
> at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:127)
> at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:80)
> at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.createChannel(NioAsyncLoadBalanceClient.java:496)
> at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.establishConnection(NioAsyncLoadBalanceClient.java:439)
> at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.communicate(NioAsyncLoadBalanceClient.java:234)
> at org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClientTask.run(NioAsyncLoadBalanceClientTask.java:81)
> at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748){code}
> The error can be seen on all nodes and only towards the node 021.
>  
> Load balancing properties are the following on ALL nodes (actual ip address instead of "ipv4_address"):
> {code:java}
> nifi.cluster.load.balance.host=ipv4_address
> nifi.cluster.load.balance.port=6342
> nifi.cluster.load.balance.connections.per.node=4
> nifi.cluster.load.balance.max.thread.count=8
> nifi.cluster.load.balance.comms.timeout=30 sec{code}
> While 18090, which is the port appearing in the error, is the HTTPS port.
> Any idea on why does the error raise? And why does it appear just towards one node?
> Thanks



--
This message was sent by Atlassian Jira
(v8.20.1#820001)