[
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 (broker.rack
not yet set for every broker) => I add broker.rack each time I update a node
from 2.8.1 to 3.1.0
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.1 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
> (broker.rack not yet set for every broker) => I add broker.rack each time I
> update a node from 2.8.1 to 3.1.0
> 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)
