Flume Avro sink failure does not retry

[centerqi hu]

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

-- 
cente...@gmail.com|齐忠