You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "someshwar (Jira)" <ji...@apache.org> on 2023/05/31 09:43:00 UTC
[jira] [Updated] (FLINK-32224) Unable to connect multiple host using RabbitMQ Connector
[ https://issues.apache.org/jira/browse/FLINK-32224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
someshwar updated FLINK-32224:
------------------------------
Description:
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.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!
was:
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!
> 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
> 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.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)