Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-6568

LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 0.10.1.1, 0.10.2.1, 0.11.0.2, 1.0.0
    • Fix Version/s: 0.11.0.3, 1.0.2, 1.1.0
    • Component/s: None
    • Labels:
      None

      Description

      LogCleanerManager.doneDeleting() removes the partition from the inProgress map without checking if the partition is paused or not. This will cause the paused partition state to be lost, and may also cause another thread calling LogCleanerManager.abortAndPauseCleaning() to block indefinitely waiting on the partition state to become paused.

        Attachments

          Activity

            People

            • Assignee:
              becket_qin Jiangjie Qin
              Reporter:
              becket_qin Jiangjie Qin
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: