flaky test

apache · Feb 16, 2024 · f94669b · f94669b
1 parent 2e6a34f
commit f94669b
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...c/test/java/org/apache/pulsar/broker/transaction/pendingack/PendingAckPersistentTest.java b/...c/test/java/org/apache/pulsar/broker/transaction/pendingack/PendingAckPersistentTest.java
@@ -460,7 +460,9 @@ public void testDeleteUselessLogDataWhenSubCursorMoved() throws Exception {
         Message<byte[]> message2 = consumer.receive(5, TimeUnit.SECONDS);
         consumer.acknowledgeAsync(message2.getMessageId(), transaction2).get();
 
-        Assert.assertEquals(pendingAckLogIndex.size(), 0);
+        Awaitility.await().untilAsserted(() -> {
+            Assert.assertEquals(pendingAckLogIndex.size(), 0);
+        });
         maxIndexLag = (long) field4.get(pendingAckStore);
         Assert.assertEquals(maxIndexLag, 5);
     }