This is an automated email from the ASF dual-hosted git repository. shishkovilja pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push: new d9c12877491 IGNITE-25720 Fix SnapshotCompressionBasicTest (#12160) d9c12877491 is described below commit d9c128774915c9bbc4d75cc00ffe4684d9643026 Author: Denis <116185428+denisp...@users.noreply.github.com> AuthorDate: Thu Sep 18 16:42:50 2025 +1000 IGNITE-25720 Fix SnapshotCompressionBasicTest (#12160) --- .../cache/persistence/snapshot/SnapshotCompressionBasicTest.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/modules/compress/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotCompressionBasicTest.java b/modules/compress/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotCompressionBasicTest.java index a3d5d28f150..ae0c2da94d2 100644 --- a/modules/compress/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotCompressionBasicTest.java +++ b/modules/compress/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotCompressionBasicTest.java @@ -17,6 +17,7 @@ package org.apache.ignite.internal.processors.cache.persistence.snapshot; +import java.io.File; import java.io.IOException; import java.nio.file.DirectoryStream; import java.nio.file.Files; @@ -203,6 +204,8 @@ public class SnapshotCompressionBasicTest extends AbstractSnapshotSelfTest { finally { locEvts.clear(); } + + awaitPartitionMapExchange(); } } @@ -257,6 +260,8 @@ public class SnapshotCompressionBasicTest extends AbstractSnapshotSelfTest { finally { locEvts.clear(); } + + awaitPartitionMapExchange(); } } @@ -288,7 +293,7 @@ public class SnapshotCompressionBasicTest extends AbstractSnapshotSelfTest { continue; } - NodeFileTree ft = nodeFileTree(dir.toString()); + NodeFileTree ft = new NodeFileTree(new File(dir.toString()), dir.getFileName().toString()); U.delete(ft.checkpoint()); U.delete(ft.db());