From fca7aeddc0a7de94a2abe5dd1d11cade6b16ac8f Mon Sep 17 00:00:00 2001 From: Vladimir Steshin Date: Thu, 11 Jul 2024 11:05:35 +0300 Subject: [PATCH] minority --- .../cache/persistence/snapshot/SnapshotChecker.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotChecker.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotChecker.java index bf5b67ec564d1..a4baf35dea79d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotChecker.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotChecker.java @@ -396,9 +396,10 @@ public Map checkSnapshotFiles( Set grpIds, SnapshotMetadata meta, boolean forCreation, - boolean skipHash, - boolean punchHoleEnabled + boolean skipHash ) throws IgniteCheckedException { + boolean pouchHoleEnabled = isPunchHoleEnabled(meta, snpDir, grpIds); + IgniteBiTuple, Set> grpAndPartFiles = preparePartitions(meta, grpIds, snpDir); Map res = new ConcurrentHashMap<>(); @@ -424,7 +425,7 @@ public Map checkSnapshotFiles( ) { pageStore.init(); - if (punchHoleEnabled && meta.isGroupWithCompression(grpId) && forCreation) { + if (pouchHoleEnabled && meta.isGroupWithCompression(grpId) && forCreation) { byte pageType = partId == INDEX_PARTITION ? FLAG_IDX : FLAG_DATA; checkPartitionsPageCrcSum(() -> pageStore, partId, pageType, (id, buffer) -> { @@ -593,7 +594,7 @@ public Map checkPartitions( if (meta.dump()) return checkDumpFiles(snpDir, meta, grps, locNode.consistentId(), skipPartsHashes); - return checkSnapshotFiles(snpDir, grps, meta, forCreation, skipPartsHashes, isPunchHoleEnabled(meta, snpDir, grps)); + return checkSnapshotFiles(snpDir, grps, meta, forCreation, skipPartsHashes); } /** */