Hi,
Try increasing connect-timeout for avro sink. set it to 100000ms and
also add request-timeout=100000.
Anand.
On 09/18/2014 07:04 AM, centerqi hu wrote:
Hi all
My flume version is 1.5.0
Flume Avro sink failure does not retry.
When the network timeout, Flume Avro sink failed, but he will not try again.
The failure of the sink will not send data.
How to let him to resend the data?
thanks
oyConnection(AbstractRpcSink.java:249)] Rpc sink k1 closing Rpc
client: NettyAvroRpcClient { host: 10.1.1.1, port: 1463 }
2014-08-28 22:55:36,264
(SinkRunner-PollingRunner-DefaultSinkProcessor) [ERROR -
org.apache.flume.SinkRunner$PollingRunner.r
un(SinkRunner.java:160)] 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:722)
Caused by: org.apache.flume.EventDeliveryException: NettyAvroRpcClient
{ host: 10.1.1.1, port: 146
3 }: Failed to send batch
at
org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:311)
at
org.apache.flume.sink.AbstractRpcSink.process(AbstractRpcSink.java:376)
... 3 more10.1.1.1, port: 146
3 }: Handshake timed out after 30000ms
at
org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:355)
at
org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:299)
... 4 more
Caused by: java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:258)
at java.util.concurrent.FutureTask.get(FutureTask.java:119)
at
org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:353)
... 5 more
