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 <[email protected]>
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());