[ https://issues.apache.org/jira/browse/KAFKA-13802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stéphane Loeuillet updated KAFKA-13802: --------------------------------------- Environment: Ubuntu 20.04.3 Adoptium 17.0.2_8 Kafka 2.13_3.1.0 with message format & interbroker protocol set to 2.8 (addition to a 2.8.1 cluster), rack awareness enabled on this node (rack not yet provided for every broker) was: Ubuntu 20.04.3 Adoptium 17.0.2_8 Kafka 2.13_3.1.0 with message format & interbroker protocol set to 2.8 (addition to a 2.8.0 cluster), rack awareness enabled on this node (rack not yet provided for every broker) > Uncaught exception in scheduled task 'flush-log' (kafka.utils.KafkaScheduler) > ----------------------------------------------------------------------------- > > Key: KAFKA-13802 > URL: https://issues.apache.org/jira/browse/KAFKA-13802 > Project: Kafka > Issue Type: Bug > Affects Versions: 3.1.0 > Environment: Ubuntu 20.04.3 > Adoptium 17.0.2_8 > Kafka 2.13_3.1.0 with message format & interbroker protocol set to 2.8 > (addition to a 2.8.1 cluster), rack awareness enabled on this node (rack not > yet provided for every broker) > Reporter: Stéphane Loeuillet > Priority: Major > > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > [2022-04-06 07:13:18,962] ERROR Uncaught exception in scheduled task > 'flush-log' (kafka.utils.KafkaScheduler) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > java.util.NoSuchElementException > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at > java.base/java.util.concurrent.ConcurrentSkipListMap$SubMap$SubMapIter.advance(Unknown > Source) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at > java.base/java.util.concurrent.ConcurrentSkipListMap$SubMap$SubMapValueIterator.next(Unknown > Source) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at > scala.collection.convert.JavaCollectionWrappers$JIteratorWrapper.next(JavaCollectionWrappers.scala:38) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at scala.collection.IterableOps.last(Iterable.scala:237) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at scala.collection.IterableOps.last$(Iterable.scala:235) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at scala.collection.AbstractIterable.last(Iterable.scala:919) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at scala.collection.IterableOps.lastOption(Iterable.scala:247) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at scala.collection.IterableOps.lastOption$(Iterable.scala:247) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at scala.collection.AbstractIterable.lastOption(Iterable.scala:919) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at kafka.log.LocalLog.flush(LocalLog.scala:174) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at kafka.log.UnifiedLog.$anonfun$flush$2(UnifiedLog.scala:1520) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at kafka.log.UnifiedLog.flush(UnifiedLog.scala:1707) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at kafka.log.UnifiedLog.$anonfun$roll$1(UnifiedLog.scala:1501) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:116) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown > Source) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at java.base/java.util.concurrent.FutureTask.run(Unknown Source) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at > java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown > Source) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown > Source) > Apr 06 07:13:18 kafka07-messaging-ovh kafka-server-start.sh[1569498]: > at java.base/java.lang.Thread.run(Unknown Source) -- This message was sent by Atlassian Jira (v8.20.1#820001)