One fix

ponder-lab · Oct 18, 2024 · d8e5718 · d8e5718
1 parent d14fe7c
commit d8e5718
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/hazelcast/src/test/java/com/hazelcast/cluster/JoinStressTest.java b/hazelcast/src/test/java/com/hazelcast/cluster/JoinStressTest.java
@@ -280,11 +280,10 @@ public void testJoinWhenMemberClosedInBetween() throws InterruptedException {
         HazelcastInstance i4 = Hazelcast.newHazelcastInstance(config);
 
         final IMap<Integer, Integer> map = i4.getMap("a");
-        int numThreads = 40;
         final int loop = 5000;
 
-        Thread[] threads = new Thread[numThreads];
-        for (int i = 0; i < numThreads; i++) {
+        Thread[] threads = new Thread[count];
+        for (int i = 0; i < count; i++) {
             threads[i] = new Thread(() -> {
                 Random random = new Random();
                 for (int j = 0; j < loop; j++) {