flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nikhil Gs <gsnikhil1432...@gmail.com>
Subject Flume Error
Date Thu, 06 Aug 2015 04:54:03 GMT
Hello Team,

Getting this error very alternatively. Unable to understand whats the
issue. Please help me out.

Thanks in advance.
ERRORorg.apache.flume.SinkRunner

Unable to deliver event. Exception follows.
org.apache.flume.EventDeliveryException: Failed to send events
	at org.apache.flume.sink.AbstractRpcSink.process(AbstractRpcSink.java:392)
	at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
	at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
	at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.flume.FlumeException: NettyAvroRpcClient { host:
sdldalplhdw02.suddenlink.cequel3.com, port: 40002 }: RPC connection
error
	at org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:182)
	at org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:121)
	at org.apache.flume.api.NettyAvroRpcClient.configure(NettyAvroRpcClient.java:638)
	at org.apache.flume.api.RpcClientFactory.getInstance(RpcClientFactory.java:89)
	at org.apache.flume.sink.AvroSink.initializeRpcClient(AvroSink.java:127)
	at org.apache.flume.sink.AbstractRpcSink.createConnection(AbstractRpcSink.java:211)
	at org.apache.flume.sink.AbstractRpcSink.verifyConnection(AbstractRpcSink.java:272)
	at org.apache.flume.sink.AbstractRpcSink.process(AbstractRpcSink.java:349)
	... 3 more
Caused by: java.io.IOException: Error connecting to
sdldalplhdw02.suddenlink.cequel3.com/10.48.210.244:40002
	at org.apache.avro.ipc.NettyTransceiver.getChannel(NettyTransceiver.java:292)
	at org.apache.avro.ipc.NettyTransceiver.<init>(NettyTransceiver.java:206)
	at org.apache.avro.ipc.NettyTransceiver.<init>(NettyTransceiver.java:155)
	at org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:168)
	... 10 more
Caused by: java.net.ConnectException: Connection refused
	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739)
	at org.jboss.netty.channel.socket.nio.NioClientBoss.connect(NioClientBoss.java:148)
	at org.jboss.netty.channel.socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:104)
	at org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:78)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
	at org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:41)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	... 1 more


Regards,
Nik.

Mime
View raw message