Hello Team,
Below is the error for my flume config. Not able to find any solution. Any
help with suggestions?
Thanks in advance.
4:56:48.844 PMERRORorg.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.
