You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "yinghua_zh (JIRA)" <ji...@apache.org> on 2015/08/28 10:39:45 UTC
[jira] [Commented] (FLUME-2774) If the avro sink take the data
from the channel failed,not need to create the rpc client again
[ 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)