From a7901a7e553d4c47065f7aa8fa0e6f2639c6508b Mon Sep 17 00:00:00 2001 From: Som Sahu Date: Tue, 19 Jan 2016 18:18:45 -0800 Subject: [PATCH] Fix: Follower crashes when offset out of range during startup modified: kafka/log/LogCleanerManager.scala --- core/src/main/scala/kafka/log/LogCleanerManager.scala | 2 -- 1 file changed, 2 deletions(-) diff --git a/core/src/main/scala/kafka/log/LogCleanerManager.scala b/core/src/main/scala/kafka/log/LogCleanerManager.scala index f6795d3..0848f15 100755 --- a/core/src/main/scala/kafka/log/LogCleanerManager.scala +++ b/core/src/main/scala/kafka/log/LogCleanerManager.scala @@ -146,8 +146,6 @@ private[log] class LogCleanerManager(val logDirs: Array[File], val logs: Pool[To case LogCleaningInProgress => inProgress.put(topicAndPartition, LogCleaningAborted) case s => - throw new IllegalStateException("Compaction for partition %s cannot be aborted and paused since it is in %s state." - .format(topicAndPartition, s)) } } while (!isCleaningInState(topicAndPartition, LogCleaningPaused)) -- 1.9.5.msysgit.1