Jun Rao created KAFKA-1544:
------------------------------
Summary: 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
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)