[jira] [Created] (KAFKA-9412) LogCleaner stopped for NoSuchElementException

["evan einst (Jira)" <ji...@apache.org>]

evan einst created KAFKA-9412:
---------------------------------

             Summary: LogCleaner stopped for NoSuchElementException
                 Key: KAFKA-9412
                 URL: https://issues.apache.org/jira/browse/KAFKA-9412
             Project: Kafka
          Issue Type: Bug
          Components: core
    Affects Versions: 0.11.0.3
            Reporter: evan einst


log cleaner stopped for NoSuchElementException when it calls CleanedTransactionMetadata.onControlBatchRead.  likes https://issues.apache.org/jira/browse/KAFKA-7467

[2019-12-31 20:35:57,527] INFO Cleaner 0: Cleaning segment 321799403 in log __consumer_offsets-30 (largest timestamp Wed Dec 04 13:48:46 CST 2019) into 321799403, discarding deletes. (kafka.log.LogCleaner)
[2019-12-31 20:35:57,600] ERROR [kafka-log-cleaner-thread-0]: Error due to (kafka.log.LogCleaner)
java.util.NoSuchElementException
 at java.util.Collections$EmptyIterator.next(Collections.java:4191)
 at kafka.log.CleanedTransactionMetadata.onControlBatchRead(LogCleaner.scala:876)
 at kafka.log.Cleaner.kafka$log$Cleaner$$shouldDiscardBatch(LogCleaner.scala:566)
 at kafka.log.Cleaner$$anon$5.checkBatchRetention(LogCleaner.scala:505)
 at org.apache.kafka.common.record.MemoryRecords.filterTo(MemoryRecords.java:155)
 at org.apache.kafka.common.record.MemoryRecords.filterTo(MemoryRecords.java:136)
 at kafka.log.Cleaner.cleanInto(LogCleaner.scala:536)
 at kafka.log.Cleaner.cleanSegments(LogCleaner.scala:444)
 at kafka.log.Cleaner.$anonfun$doClean$6(LogCleaner.scala:385)
 at kafka.log.Cleaner.$anonfun$doClean$6$adapted(LogCleaner.scala:384)
 at scala.collection.immutable.List.foreach(List.scala:389)
 at kafka.log.Cleaner.doClean(LogCleaner.scala:384)
 at kafka.log.Cleaner.clean(LogCleaner.scala:361)
 at kafka.log.LogCleaner$CleanerThread.cleanOrSleep(LogCleaner.scala:256)
 at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:236)
 at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
[2019-12-31 20:35:57,600] INFO [kafka-log-cleaner-thread-0]: Stopped (kafka.log.LogCleaner)

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)