[
https://issues.apache.org/jira/browse/KAFKA-12763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez updated KAFKA-12763:
--------------------------------
Description:
The following exception was observed in a cluster running Kafka version 2.6.2.
{code:java}
{
"class": "java.util.NoSuchElementException",
"msg": null,
"stack": [
"java.util.concurrent.ConcurrentSkipListMap$ValueIterator.next(ConcurrentSkipListMap.java:2123)",
"scala.collection.convert.JavaCollectionWrappers$JIteratorWrapper.next(JavaCollectionWrappers.scala:38)",
"scala.collection.IterableOps.head(Iterable.scala:218)",
"scala.collection.IterableOps.head$(Iterable.scala:218)",
"scala.collection.AbstractIterable.head(Iterable.scala:920)",
"kafka.log.LogManager$$anonfun$4.applyOrElse(LogManager.scala:640)",
"kafka.log.LogManager$$anonfun$4.applyOrElse(LogManager.scala:639)",
"scala.collection.Iterator$$anon$7.hasNext(Iterator.scala:516)",
"scala.collection.mutable.Growable.addAll(Growable.scala:61)",
"scala.collection.mutable.Growable.addAll$(Growable.scala:59)",
"scala.collection.mutable.HashMap.addAll(HashMap.scala:111)",
"scala.collection.mutable.HashMap$.from(HashMap.scala:549)",
"scala.collection.mutable.HashMap$.from(HashMap.scala:542)",
"scala.collection.MapFactory$Delegate.from(Factory.scala:425)",
"scala.collection.MapOps.collect(Map.scala:283)",
"scala.collection.MapOps.collect$(Map.scala:282)",
"scala.collection.AbstractMap.collect(Map.scala:375)",
"kafka.log.LogManager.$anonfun$checkpointLogStartOffsetsInDir$2(LogManager.scala:639)",
"kafka.log.LogManager.$anonfun$checkpointLogStartOffsetsInDir$1(LogManager.scala:636)",
"kafka.log.LogManager.checkpointLogStartOffsetsInDir(LogManager.scala:635)",
"kafka.log.LogManager.$anonfun$checkpointLogStartOffsets$1(LogManager.scala:600)",
"kafka.log.LogManager.$anonfun$checkpointLogStartOffsets$1$adapted(LogManager.scala:600)",
"scala.collection.IterableOnceOps.foreach(IterableOnce.scala:553)",
"scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:551)",
"scala.collection.AbstractIterable.foreach(Iterable.scala:920)",
"kafka.log.LogManager.checkpointLogStartOffsets(LogManager.scala:600)",
"kafka.log.LogManager.$anonfun$startup$6(LogManager.scala:426)",
"kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:114)",
"java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)",
"java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)",
"java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)",
"java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)",
"java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)",
"java.lang.Thread.run(Thread.java:834)"
]
}{code}
was:
The following exception was observed in a cluster running Kafka version 2.6.2.
{{}}
{code:java}
{
"class": "java.util.NoSuchElementException",
"msg": null,
"stack": [
"java.util.concurrent.ConcurrentSkipListMap$ValueIterator.next(ConcurrentSkipListMap.java:2123)",
"scala.collection.convert.JavaCollectionWrappers$JIteratorWrapper.next(JavaCollectionWrappers.scala:38)",
"scala.collection.IterableOps.head(Iterable.scala:218)",
"scala.collection.IterableOps.head$(Iterable.scala:218)",
"scala.collection.AbstractIterable.head(Iterable.scala:920)",
"kafka.log.LogManager$$anonfun$4.applyOrElse(LogManager.scala:640)",
"kafka.log.LogManager$$anonfun$4.applyOrElse(LogManager.scala:639)",
"scala.collection.Iterator$$anon$7.hasNext(Iterator.scala:516)",
"scala.collection.mutable.Growable.addAll(Growable.scala:61)",
"scala.collection.mutable.Growable.addAll$(Growable.scala:59)",
"scala.collection.mutable.HashMap.addAll(HashMap.scala:111)",
"scala.collection.mutable.HashMap$.from(HashMap.scala:549)",
"scala.collection.mutable.HashMap$.from(HashMap.scala:542)",
"scala.collection.MapFactory$Delegate.from(Factory.scala:425)",
"scala.collection.MapOps.collect(Map.scala:283)",
"scala.collection.MapOps.collect$(Map.scala:282)",
"scala.collection.AbstractMap.collect(Map.scala:375)",
"kafka.log.LogManager.$anonfun$checkpointLogStartOffsetsInDir$2(LogManager.scala:639)",
"kafka.log.LogManager.$anonfun$checkpointLogStartOffsetsInDir$1(LogManager.scala:636)",
"kafka.log.LogManager.checkpointLogStartOffsetsInDir(LogManager.scala:635)",
"kafka.log.LogManager.$anonfun$checkpointLogStartOffsets$1(LogManager.scala:600)",
"kafka.log.LogManager.$anonfun$checkpointLogStartOffsets$1$adapted(LogManager.scala:600)",
"scala.collection.IterableOnceOps.foreach(IterableOnce.scala:553)",
"scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:551)",
"scala.collection.AbstractIterable.foreach(Iterable.scala:920)",
"kafka.log.LogManager.checkpointLogStartOffsets(LogManager.scala:600)",
"kafka.log.LogManager.$anonfun$startup$6(LogManager.scala:426)",
"kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:114)",
"java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)",
"java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)",
"java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)",
"java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)",
"java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)",
"java.lang.Thread.run(Thread.java:834)"
]
}{code}
> NoSuchElementException during kafka-log-start-offset-checkpoint
> ---------------------------------------------------------------
>
> Key: KAFKA-12763
> URL: https://issues.apache.org/jira/browse/KAFKA-12763
> Project: Kafka
> Issue Type: Bug
> Components: log
> Affects Versions: 2.6.2
> Reporter: Igor Soarez
> Assignee: Igor Soarez
> Priority: Minor
>
> The following exception was observed in a cluster running Kafka version 2.6.2.
>
> {code:java}
> {
> "class": "java.util.NoSuchElementException",
> "msg": null,
> "stack": [
>
> "java.util.concurrent.ConcurrentSkipListMap$ValueIterator.next(ConcurrentSkipListMap.java:2123)",
>
> "scala.collection.convert.JavaCollectionWrappers$JIteratorWrapper.next(JavaCollectionWrappers.scala:38)",
> "scala.collection.IterableOps.head(Iterable.scala:218)",
> "scala.collection.IterableOps.head$(Iterable.scala:218)",
> "scala.collection.AbstractIterable.head(Iterable.scala:920)",
> "kafka.log.LogManager$$anonfun$4.applyOrElse(LogManager.scala:640)",
> "kafka.log.LogManager$$anonfun$4.applyOrElse(LogManager.scala:639)",
> "scala.collection.Iterator$$anon$7.hasNext(Iterator.scala:516)",
> "scala.collection.mutable.Growable.addAll(Growable.scala:61)",
> "scala.collection.mutable.Growable.addAll$(Growable.scala:59)",
> "scala.collection.mutable.HashMap.addAll(HashMap.scala:111)",
> "scala.collection.mutable.HashMap$.from(HashMap.scala:549)",
> "scala.collection.mutable.HashMap$.from(HashMap.scala:542)",
> "scala.collection.MapFactory$Delegate.from(Factory.scala:425)",
> "scala.collection.MapOps.collect(Map.scala:283)",
> "scala.collection.MapOps.collect$(Map.scala:282)",
> "scala.collection.AbstractMap.collect(Map.scala:375)",
>
> "kafka.log.LogManager.$anonfun$checkpointLogStartOffsetsInDir$2(LogManager.scala:639)",
>
> "kafka.log.LogManager.$anonfun$checkpointLogStartOffsetsInDir$1(LogManager.scala:636)",
>
> "kafka.log.LogManager.checkpointLogStartOffsetsInDir(LogManager.scala:635)",
>
> "kafka.log.LogManager.$anonfun$checkpointLogStartOffsets$1(LogManager.scala:600)",
>
> "kafka.log.LogManager.$anonfun$checkpointLogStartOffsets$1$adapted(LogManager.scala:600)",
> "scala.collection.IterableOnceOps.foreach(IterableOnce.scala:553)",
> "scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:551)",
> "scala.collection.AbstractIterable.foreach(Iterable.scala:920)",
> "kafka.log.LogManager.checkpointLogStartOffsets(LogManager.scala:600)",
> "kafka.log.LogManager.$anonfun$startup$6(LogManager.scala:426)",
>
> "kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:114)",
> "java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)",
> "java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)",
>
> "java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)",
>
> "java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)",
>
> "java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)",
> "java.lang.Thread.run(Thread.java:834)"
> ]
> }{code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
