You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "evan einst (Jira)" <ji...@apache.org> on 2020/01/13 08:23:00 UTC
[jira] [Updated] (KAFKA-9412) LogCleaner stopped for
NoSuchElementException
[ https://issues.apache.org/jira/browse/KAFKA-9412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
evan einst updated KAFKA-9412:
------------------------------
Description:
log cleaner stopped for NoSuchElementException when it calls CleanedTransactionMetadata.onControlBatchRead. likes https://issues.apache.org/jira/browse/KAFKA-7467
{code:java}
[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){code}
was:
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)
> 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
> Priority: Major
>
> log cleaner stopped for NoSuchElementException when it calls CleanedTransactionMetadata.onControlBatchRead. likes https://issues.apache.org/jira/browse/KAFKA-7467
> {code:java}
> [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){code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)