Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-2632

High CPU on KafkaSink

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.5.1
    • Fix Version/s: 1.7.0
    • Component/s: Sinks+Sources
    • Labels:

      Description

      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. "

        Attachments

        Issue Links

          Activity

            People

            • Assignee:
              paliwalashish Ashish Paliwal
              Reporter:
              gwenshap Gwen Shapira

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment