Uploaded image for project: 'WildFly'
  1. WildFly
  2. WFLY-18877

ActiveMQ/Artemis in Kubernetes Environment

    XMLWordPrintable

Details

    • Bug
    • Resolution: Unresolved
    • Major
    • None
    • 27.0.1.Final, 30.0.1.Final
    • Clustering, JMS
    • None
    • Hide

      Start two instances within a Kubernetes Cluster using KUBE_PING.

      Show
      Start two instances within a Kubernetes Cluster using KUBE_PING.
    • ---
    • ---

    Description

      When starting multiple instances within Kubernetes using KUBE_PING. The following errors are reported multiple times:

      06:32:11,497 WARN  [org.apache.activemq.artemis.core.server] (Thread-2 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@49076176)) AMQ224091: Bridge ClusterConnectionBridge@77948ba5 [name=$.artemis.internal.sf.my-cluster.dbe1d6af-a4c4-11ee-8832-aee1c4002e01, queue=QueueImpl[name=$.artemis.internal.sf.my-cluster.dbe1d6af-a4c4-11ee-8832-aee1c4002e01, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::name=default], temp=false]@5ac9f7b3 targetConnector=ServerLocatorImpl (identity=(Cluster-connection-bridge::ClusterConnectionBridge@77948ba5 [name=$.artemis.internal.sf.my-cluster.dbe1d6af-a4c4-11ee-8832-aee1c4002e01, queue=QueueImpl[name=$.artemis.internal.sf.my-cluster.dbe1d6af-a4c4-11ee-8832-aee1c4002e01, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::name=default], temp=false]@5ac9f7b3 targetConnector=ServerLocatorImpl [initialConnectors=[TransportConfiguration(name=http-connector, factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory) ?httpUpgradeEndpoint=http-acceptor&activemqServerName=default&httpUpgradeEnabled=true&port=8080&host=uq-fw-857796fcd4-kx8pc], discoveryGroupConfiguration=null]]::ClusterConnectionImpl@1083874991[nodeUUID=6ccc7fd4-a542-11ee-98e8-9eaec52c72b7, connector=TransportConfiguration(name=http-connector, factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory) ?httpUpgradeEndpoint=http-acceptor&activemqServerName=default&httpUpgradeEnabled=true&port=8080&host=uq-fw-857796fcd4-7k9v9, address=jms, server=ActiveMQServerImpl::name=default])) [initialConnectors=[TransportConfiguration(name=http-connector, factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory) ?httpUpgradeEndpoint=http-acceptor&activemqServerName=default&httpUpgradeEnabled=true&port=8080&host=uq-fw-857796fcd4-kx8pc], discoveryGroupConfiguration=null]] is unable to connect to destination. Retrying
      
      06:32:12,038 ERROR [org.apache.activemq.artemis.core.client] (Thread-1 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@49076176)) AMQ214016: Failed to create netty connection: java.net.UnknownHostException: uq-fw-857796fcd4-kx8pc
          at java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)
          at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1533)
          at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1386)
          at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1307)
          at java.base/java.net.InetAddress.getByName(InetAddress.java:1257)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)
          at java.base/java.security.AccessController.doPrivileged(Native Method)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)
          at io.netty.netty-resolver@4.1.84.Final//io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)
          at io.netty.netty-resolver@4.1.84.Final//io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)
          at io.netty.netty-resolver@4.1.84.Final//io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)
          at io.netty.netty-resolver@4.1.84.Final//io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)
          at io.netty.netty-resolver@4.1.84.Final//io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)
          at io.netty.netty-resolver@4.1.84.Final//io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)
          at io.netty.netty-transport@4.1.84.Final//io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)
          at io.netty.netty-transport@4.1.84.Final//io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
          at io.netty.netty-transport@4.1.84.Final//io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
          at io.netty.netty-transport@4.1.84.Final//io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
          at io.netty.netty-transport@4.1.84.Final//io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
          at io.netty.netty-transport@4.1.84.Final//io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)
          at io.netty.netty-transport@4.1.84.Final//io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
          at io.netty.netty-transport@4.1.84.Final//io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
          at io.netty.netty-transport@4.1.84.Final//io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
          at io.netty.netty-transport-native-epoll@4.1.84.Final//io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:406)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
          at io.netty.netty-common@4.1.84.Final//io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
          at org.apache.activemq.artemis.journal//org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)

      A connection attempt is done to the first member of the pods found by KUBE_PING: 

      06:32:02,776 INFO [org.infinispan.CLUSTER] (ServerService Thread Pool – 91) ISPN000094: Received new cluster view for channel ejb: [uq-fw-857796fcd4-kx8pc|1] (2) [uq-fw-857796fcd4-kx8pc, uq-fw-857796fcd4-7k9v9]

      But this fails because there is no DNS entry for the name of the pod.
      I am not very familiar with JMS but a connection via IP address may solve the problem. Maybe another solution exists, but a can't find one.
       

       

       

       

       

       

       

       

      Attachments

        Activity

          People

            pferraro@redhat.com Paul Ferraro
            uqpik Joachim Piketz (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: