Igor Soarez created KAFKA-12763:
-----------------------------------
Summary: 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
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)
