commit 517d586b52945cf46ed7dff07d56092b0d56c6b6
author Shishkov Ilya <shishkovilja@gmail.com> Fri Apr 30 12:44:10 2021 +0300
committer GitHub <noreply@github.com> Fri Apr 30 12:44:10 2021 +0300
tree abf773015dbacf360b3f6bca826952721481c2e6
parent da776554ae23232bbd3a78c8e9505e8068c1ffe8

IGNITE-14671 Fix flaky testClusterSnapshotCheckOtherCluster (#9068)

modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteClusterSnapshotCheckTest.java

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
index 23e18f3..4527125 100644
--- 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
@@ -284,7 +284,7 @@
             .filter(f -> !f.getName().equals(DFLT_SNAPSHOT_DIRECTORY))
             .forEach(U::delete);
 
-        Set<UUID> assigns = new HashSet<>();
+        Set<UUID> 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);