[KAFKA-1544] LogCleaner may take a long time to shutdown

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.8.2.0
• Fix Version/s: 0.8.2.0
• Component/s: core
• Labels: newbie
• Assignee: Manikumar
• Reporter: Jun Rao
• Created: 17/Jul/14 14:47
• Updated: 24/Jul/14 23:35
• Resolved: 24/Jul/14 23:35

Description

We have the following code in LogCleaner. Since the cleaner thread is shutdown w/o interrupt. If may take up to backoff time for the cleaner thread to detect the shutdown flag.

private def cleanOrSleep() {
cleanerManager.grabFilthiestLog() match {
case None =>
// there are no cleanable logs, sleep a while
time.sleep(config.backOffMs)