[ https://issues.apache.org/jira/browse/KAFKA-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Manikumar Reddy updated KAFKA-1544: ----------------------------------- Attachment: KAFKA-1544_2014-07-24_20:38:52.patch > LogCleaner may take a long time to shutdown > ------------------------------------------- > > Key: KAFKA-1544 > URL: https://issues.apache.org/jira/browse/KAFKA-1544 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.8.2 > Reporter: Jun Rao > Assignee: Manikumar Reddy > Labels: newbie > Attachments: KAFKA-1544.patch, KAFKA-1544_2014-07-24_20:38:52.patch > > > 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) > -- This message was sent by Atlassian JIRA (v6.2#6252)