[
https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14968205#comment-14968205
]
Hudson commented on FLUME-2632:
-------------------------------
SUCCESS: Integrated in Flume-trunk-hbase-1 #130 (See
[https://builds.apache.org/job/Flume-trunk-hbase-1/130/])
FLUME-2632: High CPU on KafkaSink (johnyrufus:
[http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=d6bf08b54e467a6bdc6a5fc0edd41c51200e9da1])
*
flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java
*
flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
> High CPU on KafkaSink
> ---------------------
>
> Key: FLUME-2632
> URL: https://issues.apache.org/jira/browse/FLUME-2632
> Project: Flume
> Issue Type: Bug
> Components: Sinks+Sources
> Affects Versions: v1.5.1
> Reporter: Gwen Shapira
> Assignee: Ashish Paliwal
> Labels: kafka
> Fix For: v1.7.0
>
> Attachments: FLUME-2632-0.patch
>
>
> Reported here: https://github.com/harishreedharan/flume/issues/1
> "I tried flume-ng-kafka-sink and it worked fine. But I noticed that the cpu
> utilization stay at 100% and never dropped down all the time even at the time
> the channel is empty.
> I looked into the source code and found that "process" function in KafkaSink
> always return Status.READY even if no events available in channel. That
> causes the SinkRunner keep running achieving event from channel and get
> nothing.
> Do we need to change to return Status.BACKOFF in "process" function in
> KafkaSink when it notices that there is no events processed in current round?
> So that the SinkRunner has a chance to take a rest when there is no event in
> channel. If this proposal feasible, function "testEmptyChannel" in
> TestKafkaSink also need to be changed. "
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
