Index: modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteClusterSnapshotCheckTest.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteClusterSnapshotCheckTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteClusterSnapshotCheckTest.java --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteClusterSnapshotCheckTest.java (revision 01e3899653d10c478beefcedff388dd657be5ba5) +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteClusterSnapshotCheckTest.java (date 1619710875524) @@ -284,7 +284,7 @@ .filter(f -> !f.getName().equals(DFLT_SNAPSHOT_DIRECTORY)) .forEach(U::delete); - Set assigns = new HashSet<>(); + Set assigns = Collections.newSetFromMap(new ConcurrentHashMap<>()); for (int i = 4; i < 7; i++) { startGrid(optimize(getConfiguration(getTestIgniteInstanceName(i)).setCacheConfiguration())); @@ -313,8 +313,8 @@ res.print(b::append, true); // GridJobExecuteRequest is not send to the local node. - assertTrue("Number of jobs must be equal to the cluster size (except local node): " + assigns, - waitForCondition(() -> assigns.size() == 2, 5_000L)); + assertTrue("Number of jobs must be equal to the cluster size (except local node): " + assigns + ", count: " + + assigns.size(), waitForCondition(() -> assigns.size() == 2, 5_000L)); assertTrue(F.isEmpty(res.exceptions())); assertPartitionsSame(res);