someshwar created FLINK-32224:
---------------------------------
Summary: Unable to connect multiple host using RabbitMQ Connector
Key: FLINK-32224
URL: https://issues.apache.org/jira/browse/FLINK-32224
Project: Flink
Issue Type: Bug
Components: Connectors/ RabbitMQ
Affects Versions: 1.14.2
Reporter: someshwar
Fix For: 1.14.2
i have used same implement provided in below link
[https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/rabbitmq/]
when i using with multiple host with comma separated get below issue
at
org.apache.flink.streaming.connectors.rabbitmq.RMQSource.open(RMQSource.java:267)
at
org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:110)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:711)
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.call(StreamTaskActionExecutor.java:100)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:687)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:654)
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.net.UnknownHostException: No such host is known
(10.36.2.253,10.36.2.254,10.36.2.255)
at java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)
at
java.base/java.net.InetAddress$PlatformNameService.lookupAllHostAddr(InetAddress.java:928)
at
java.base/java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1514)
at
java.base/java.net.InetAddress$NameServiceAddresses.get(InetAddress.java:847)
at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1504)
at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1363)
at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1297)
at
com.rabbitmq.client.DnsRecordIpAddressResolver.resolveIpAddresses(DnsRecordIpAddressResolver.java:83)
at
com.rabbitmq.client.DnsRecordIpAddressResolver.getAddresses(DnsRecordIpAddressResolver.java:73)
at
com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:58)
at
com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156)
at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1130)
at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1087)
at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1045)
at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1207)
at
org.apache.flink.streaming.connectors.rabbitmq.RMQSource.setupConnection(RMQSource.java:204)
at
org.apache.flink.streaming.connectors.rabbitmq.RMQSource.open(RMQSource.java:240)
... 12 more!MicrosoftTeams-image (59).png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
