[
https://issues.apache.org/jira/browse/KAFKA-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071937#comment-14071937
]
Manikumar Reddy commented on KAFKA-1544:
----------------------------------------
Created reviewboard https://reviews.apache.org/r/23858/diff/
against branch origin/trunk
> 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
> Labels: newbie
> Attachments: KAFKA-1544.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)
