Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-32224

Unable to connect multiple host using RabbitMQ Connector

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.14.2
    • None
    • Connectors/ RabbitMQ
    • None

    Description

      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!

      Attachments

        Activity

          People

            Unassigned Unassigned
            someshwar.reddy someshwar
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: