flaky test: testReplicatorWithFailedAck

apache · Feb 16, 2024 · 1438b32 · 1438b32
1 parent f94669b
commit 1438b32
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java
@@ -1682,6 +1682,7 @@ public void testReplicatorWithFailedAck() throws Exception {
 
         MessageIdImpl lastMessageId = (MessageIdImpl) topic.getLastMessageId().get();
         Position lastPosition = PositionImpl.get(lastMessageId.getLedgerId(), lastMessageId.getEntryId());
+        Awaitility.await().untilAsserted(() -> assertNotNull(topic.getReplicators().get("r2")));
         ConcurrentOpenHashMap<String, Replicator> replicators = topic.getReplicators();
         PersistentReplicator replicator = (PersistentReplicator) replicators.get("r2");