[
https://issues.apache.org/jira/browse/FLUME-2774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14718221#comment-14718221
]
yinghua_zh commented on FLUME-2774:
-----------------------------------
If the avro sink take the data from the channel failed,not need to create the
rpc client again,the exception as follows:
2015-08-22 14:09:36,884 | ERROR |
[SinkRunner-PollingRunner-DefaultSinkProcessor] | Unable to deliver event.
Exception follows. | org.apache.flume.SinkRunn
er$PollingRunner.run(SinkRunner.java:160)
org.apache.flume.EventDeliveryException: Failed to send events
at
org.apache.flume.sink.AbstractRpcSink.process(AbstractRpcSink.java:448)
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: java.lang.IllegalStateException: Empty value
[channel=[channel=static_test_channel]]
at
com.google.common.base.Preconditions.checkState(Preconditions.java:145)
at
org.apache.flume.channel.file.FlumeEventQueue.removeHead(FlumeEventQueue.java:160)
at
org.apache.flume.channel.file.FileChannel$FileBackedTransaction.doTake(FileChannel.java:514)
at
org.apache.flume.channel.BasicTransactionSemantics.take(BasicTransactionSemantics.java:113)
at
org.apache.flume.channel.BasicChannelSemantics.take(BasicChannelSemantics.java:95)
at
org.apache.flume.sink.AbstractRpcSink.process(AbstractRpcSink.java:393)
The avro sink take the data failed,it throw the
java.lang.IllegalStateException,it is not the ChannelException,so it will
create the rpc client again when it sends the data to the avro source at the
next 5 seconds.But it does not need to do it.
> If the avro sink take the data from the channel failed,not need to create
> the rpc client again
> -----------------------------------------------------------------------------------------------
>
> Key: FLUME-2774
> URL: https://issues.apache.org/jira/browse/FLUME-2774
> Project: Flume
> Issue Type: Improvement
> Affects Versions: 1.6
> Reporter: yinghua_zh
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
