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)
