[
https://issues.apache.org/jira/browse/FLINK-32224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729622#comment-17729622
]
Martijn Visser commented on FLINK-32224:
----------------------------------------
[~someshwar.reddy] It's not deprecated, but there are no maintainers for the
project at this moment
> 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
> Priority: Major
>
> i have used same implemention 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.43.2.678,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)
