MINOR: Remove redundant try block in LogCleaner
Reviewers: Stanislav Kozlovski Ismael Juma
@@ -321,13 +321,10 @@ class LogCleaner(initialConfig: CleanerConfig,
}
val deletable: Iterable[(TopicPartition, Log)] = cleanerManager.deletableLogs()
try {
- deletable.foreach {
- case (topicPartition, log) =>
- try {
+ deletable.foreach { case (topicPartition, log) =>
currentLog = Some(log)
log.deleteOldSegments()
}
- }
} finally {
cleanerManager.doneDeleting(deletable.map(_._1))
}
