Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-2210

UnresolvedAddressException when using multiple hostNames in Elasticsearch sink configuration

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.4.0
    • Fix Version/s: 1.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)
      

        Attachments

          Activity

            People

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

              Dates

              • Created:
                Updated:
                Resolved: