[FLUME-2210] UnresolvedAddressException when using multiple hostNames in Elasticsearch sink configuration

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.4.0
• Fix Version/s: 1.5.0
• Component/s: Sinks+Sources
• Labels: elasticsearch sink

Environment

Centos 6
Elasticsearch 0.90.5
Lucene 4.4.0
Java 1.7

• Assignee: Dib Ghosh
• Reporter: Nikolaos Tsipas
• Created: 10/Oct/13 16:19
• Updated: 25/Oct/13 02:12
• Resolved: 25/Oct/13 00:48

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)