[KAFKA-6568] LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

• 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
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Created: 15/Feb/18 22:45
• Updated: 20/Feb/18 15:19
• Resolved: 17/Feb/18 02:25

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.

Issue Links

• links to: GitHub Pull Request #4580
• links to: GitHub Pull Request #4592