Changed conditionDetails and removed declared maxTime

chiacyu · Apr 12, 2024 · 1de9008 · 1de9008
1 parent 9b2c8ab
commit 1de9008
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/server/src/test/java/org/apache/kafka/server/AssignmentsManagerTest.java b/server/src/test/java/org/apache/kafka/server/AssignmentsManagerTest.java
@@ -176,7 +176,7 @@ public void testAssignmentAggregation() throws InterruptedException {
             time.sleep(100);
             manager.wakeup();
             return readyToAssert.await(1, TimeUnit.MILLISECONDS);
-        }, 1000, "Wait for ready to assert.");
+        }, "Timed out waiting for AssignReplicasToDirsRequest to be sent.");
 
         ArgumentCaptor<AssignReplicasToDirsRequest.Builder> captor =
             ArgumentCaptor.forClass(AssignReplicasToDirsRequest.Builder.class);
@@ -249,7 +249,7 @@ void testRequeuesFailedAssignmentPropagations() throws InterruptedException {
             time.sleep(TimeUnit.SECONDS.toMillis(1));
             manager.wakeup();
             return readyToAssert.await(1, TimeUnit.MILLISECONDS);
-        }, 10000, "Wait for ready to assert.");
+        }, "Timed out waiting for AssignReplicasToDirsRequest to be sent.");
 
         ArgumentCaptor<AssignReplicasToDirsRequest.Builder> captor =
             ArgumentCaptor.forClass(AssignReplicasToDirsRequest.Builder.class);
@@ -301,7 +301,7 @@ void testOnCompletion() throws Exception {
             time.sleep(TimeUnit.SECONDS.toMillis(1));
             manager.wakeup();
             return readyToAssert.await(1, TimeUnit.MILLISECONDS);
-        }, 10000, "Wait for ready to assert");
+        }, "Timed out waiting for AssignReplicasToDirsRequest to be sent.");
     }
 
     private static ClientResponse buildSuccessfulResponse(AssignReplicasToDirsRequestData request) {
@@ -391,7 +391,7 @@ void testQueuedReplicaToDirAssignmentsMetric() throws Exception {
         TestUtils.waitForCondition(() -> {
             time.sleep(100);
             return readyToAssert.await(1, TimeUnit.MILLISECONDS);
-        }, 1000, "Wait for ready to assert");
+        }, "Timed out waiting for AssignReplicasToDirsRequest to be sent.");
         assertEquals(4, queuedReplicaToDirAssignments.value());
 
         for (int i = 4; i < 8; i++) {