[ https://issues.apache.org/jira/browse/KAFKA-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jason Gustafson resolved KAFKA-6568. ------------------------------------ Resolution: Fixed Fix Version/s: 1.0.2 0.11.0.3 > LogCleanerManager.doneDeleting() should check the partition state before > deleting the in progress partition > ----------------------------------------------------------------------------------------------------------- > > Key: KAFKA-6568 > URL: https://issues.apache.org/jira/browse/KAFKA-6568 > Project: Kafka > Issue Type: Bug > Affects Versions: 0.10.1.1, 0.10.2.1, 1.0.0, 0.11.0.2 > Reporter: Jiangjie Qin > Assignee: Jiangjie Qin > Priority: Blocker > Fix For: 1.1.0, 0.11.0.3, 1.0.2 > > > {{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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)