Skip to content
代码片段 群组 项目
未验证 提交 5a2f28ce 编辑于 作者: José Armando García Sancio's avatar José Armando García Sancio 提交者: GitHub
浏览文件

MINOR; Synchronize access to snapshots' TreeMap (#12464)

Read and write access to the TreeMap in snapshots needs to be synchronized.

Reviewers: David Arthur <mumrah@gmail.com>
上级 6ace67b2
No related branches found
No related tags found
无相关合并请求
......@@ -257,7 +257,11 @@ final class KafkaMetadataLog private (
}
override def storeSnapshot(snapshotId: OffsetAndEpoch): Optional[RawSnapshotWriter] = {
if (snapshots.contains(snapshotId)) {
val containsSnapshotId = snapshots synchronized {
snapshots.contains(snapshotId)
}
if (containsSnapshotId) {
Optional.empty()
} else {
Optional.of(FileRawSnapshotWriter.create(log.dir.toPath, snapshotId, Optional.of(this)))
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册