Skip to content

Unexpected called of ElasticStreamSlice.fetch after partition reassignment #502

@Chillax-0v0

Description

@Chillax-0v0

stack:

ts=2023-12-01 08:55:14;thread_name=data-plane-kafka-request-handler-10;id=81;is_daemon=true;priority=5;TCCL=jdk.internal.loader.ClassLoaders$AppClassLoader@251a69d7
    @kafka.log.streamaspect.DefaultElasticStreamSlice.fetch()
        at kafka.log.streamaspect.ElasticStreamSlice.fetch(ElasticStreamSlice.java:53)
        at kafka.log.streamaspect.ElasticLogFileRecords$StreamSegmentInputStream.nextBatch(ElasticLogFileRecords.java:365)
        at org.apache.kafka.common.record.RecordBatchIterator.makeNext(RecordBatchIterator.java:37)
        at org.apache.kafka.common.record.RecordBatchIterator.makeNext(RecordBatchIterator.java:26)
        at org.apache.kafka.common.utils.AbstractIterator.maybeComputeNext(AbstractIterator.java:79)
        at org.apache.kafka.common.utils.AbstractIterator.hasNext(AbstractIterator.java:45)
        at kafka.log.streamaspect.ElasticLogSegment.loadFirstBatchTimestamp(ElasticLogSegment.scala:314)
        at kafka.log.streamaspect.ElasticLogSegment.timeWaitedForRoll(ElasticLogSegment.scala:321)
        at kafka.log.streamaspect.ElasticLogSegment.shouldRoll(ElasticLogSegment.scala:55)
        at kafka.log.UnifiedLog.maybeRoll(UnifiedLog.scala:1525)
        at kafka.log.UnifiedLog.$anonfun$append$2(UnifiedLog.scala:925)
        at kafka.log.LocalLog$.maybeHandleIOException(LocalLog.scala:820)
        at kafka.log.streamaspect.ElasticUnifiedLog.maybeHandleIOException(ElasticUnifiedLog.scala:59)
        at kafka.log.UnifiedLog.append(UnifiedLog.scala:827)
        at kafka.log.UnifiedLog.appendAsLeader(UnifiedLog.scala:766)
        at kafka.cluster.Partition.$anonfun$appendRecordsToLeader$1(Partition.scala:1290)
        at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:1271)
        at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$6(ReplicaManager.scala:1006)
        at scala.collection.StrictOptimizedMapOps.map(StrictOptimizedMapOps.scala:28)
        at scala.collection.StrictOptimizedMapOps.map$(StrictOptimizedMapOps.scala:27)
        at scala.collection.mutable.HashMap.map(HashMap.scala:35)
        at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:994)
        at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:652)
        at kafka.server.KafkaApis.doAppendRecords$1(KafkaApis.scala:768)
        at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:779)
        at kafka.server.KafkaApis.handle(KafkaApis.scala:251)
        at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:77)
        at java.lang.Thread.run(Thread.java:840)

Metadata

Metadata

Assignees

Labels

bugSomething isn't working

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions