[KAFKA-13098] No such file exception when recovering snapshots in metadata log dir

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 3.0.0
• Fix Version/s: 3.0.0
• Labels: kip-500
• Assignee: Jose Armando Garcia Sancio
• Reporter: Jose Armando Garcia Sancio
• Created: 16/Jul/21 18:14
• Updated: 17/Jul/21 18:34
• Resolved: 17/Jul/21 18:34

Description

RaftClusterTest > testCreateClusterAndCreateListDeleteTopic() FAILED
    java.io.UncheckedIOException: java.nio.file.NoSuchFileException: /tmp/kafka-286994548094074875/broker_0_data0/@metadata-0/partition.metadata.tmp
        at java.nio.file.FileTreeIterator.fetchNextIfNeeded(FileTreeIterator.java:88)
        at java.nio.file.FileTreeIterator.hasNext(FileTreeIterator.java:104)
        at java.util.Iterator.forEachRemaining(Iterator.java:115)
        at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
        at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)                                       
        at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
        at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
        at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)                                                                                                                                                                                   
        at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
        at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
        at kafka.raft.KafkaMetadataLog$.recoverSnapshots(KafkaMetadataLog.scala:616)
        at kafka.raft.KafkaMetadataLog$.apply(KafkaMetadataLog.scala:583)                  
        at kafka.raft.KafkaRaftManager.buildMetadataLog(RaftManager.scala:257)
        at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:132)                                                                                                                                                                                                             
        at kafka.testkit.KafkaClusterTestKit$Builder.build(KafkaClusterTestKit.java:227)
        at kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic(RaftClusterTest.scala:87) 

Issue Links

• links to: GitHub Pull Request #11071