You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Jose Armando Garcia Sancio (Jira)" <ji...@apache.org> on 2021/07/17 18:35:00 UTC
[jira] [Resolved] (KAFKA-13098) No such file exception when
recovering snapshots in metadata log dir
[ https://issues.apache.org/jira/browse/KAFKA-13098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jose Armando Garcia Sancio resolved KAFKA-13098.
------------------------------------------------
Resolution: Fixed
> No such file exception when recovering snapshots in metadata log dir
> --------------------------------------------------------------------
>
> Key: KAFKA-13098
> URL: https://issues.apache.org/jira/browse/KAFKA-13098
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 3.0.0
> Reporter: Jose Armando Garcia Sancio
> Assignee: Jose Armando Garcia Sancio
> Priority: Blocker
> Labels: kip-500
> Fix For: 3.0.0
>
>
> {code:java}
> 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) {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)