Flume
  1. Flume
  2. FLUME-2210

UnresolvedAddressException when using multiple hostNames in Elasticsearch sink configuration

    Details

    • Type: Bug Bug
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: v1.4.0
    • Fix Version/s: v1.5.0
    • Component/s: Sinks+Sources
    • Environment:

      Centos 6
      Elasticsearch 0.90.5
      Lucene 4.4.0
      Java 1.7

      Description

      Hello,

      I receive the following error when I define multiple hostnames in elasticsearch sink configuration.

      These work

      a1.sinks.k2.hostNames = 10.0.110.50:9300
      
      a1.sinks.k2.hostNames = 10.0.110.51:9300
      

      This doesn't

      a1.sinks.k2.hostNames = 10.0.110.50:9300, 10.0.110.51:9300
      

      Could be a bug? According to flume documentation the hostNames property is a "Comma separated list of hostname:port" .

      10 Oct 2013 16:09:14,077 WARN  [elasticsearch[Big Man][generic][T#1]] (org.elasticsearch.common.logging.log4j.Log4jESLogger.internalWarn:129)  - [Big Man] exception caught on transport layer [[id: 0xac7f61fa]], closing connection
      java.nio.channels.UnresolvedAddressException
      	at sun.nio.ch.Net.checkAddress(Net.java:127)
      	at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:613)
      	at org.elasticsearch.common.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:108)
      	at org.elasticsearch.common.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70)
      	at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:574)
      	at org.elasticsearch.common.netty.channel.Channels.connect(Channels.java:634)
      	at org.elasticsearch.common.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
      	at org.elasticsearch.common.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
      	at org.elasticsearch.common.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
      	at org.elasticsearch.transport.netty.NettyTransport.connectToChannels(NettyTransport.java:662)
      	at org.elasticsearch.transport.netty.NettyTransport.connectToNode(NettyTransport.java:608)
      	at org.elasticsearch.transport.netty.NettyTransport.connectToNode(NettyTransport.java:576)
      	at org.elasticsearch.transport.TransportService.connectToNode(TransportService.java:129)
      	at org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler.sample(TransportClientNodesService.java:305)
      	at org.elasticsearch.client.transport.TransportClientNodesService$ScheduledNodeSampler.run(TransportClientNodesService.java:284)
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
      	at java.lang.Thread.run(Thread.java:724)
      

        Activity

        No work has yet been logged on this issue.

          People

          • Assignee:
            Dib Ghosh
            Reporter:
            Nikolaos Tsipas
          • Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development