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

Fix handling interruption of blocked WALSource

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 0.9.4
    • None
    • None

    Description

      The getUnackedSource call in NaiveFileWALManager blocks if there are no elements to process in queue. If interrupted and the logged and sent queues are empty, this should exit cleanly. If both logged and sent queues are empty we can definitely exit with without error.

      If the logged queue still contains data, and this is interrupted, it should definitely fail.

      It is debatable if we should exit cleanly if the logged queue is empty and the sent queue is not (sent but not acked). This patch exits cleanly only if the ack has been received as well.

      Attachments

        Issue Links

          blocks

          Epic - Created by Jira Software - do not edit or delete. Issue type for a big user story that needs to be broken down. FLUME-592 Fix intermittent / flaky tests for v0.9.4

          • Blocker - Blocks development and/or testing work, production could not run
          • Closed

          Activity

            People

              jmhsieh Jonathan Hsieh
              jmhsieh Jonathan Hsieh
              Votes:
              0 Vote for this issue
              Watchers:
              0 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: