This is an automated email from the ASF dual-hosted git repository. zhaocong pushed a commit to branch branch-2.10.5.3-a41ecf in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 28cd8dca33c07748e5658456e519fb6b13debc11 Author: Mattison Chao <[email protected]> AuthorDate: Fri Dec 29 23:13:52 2023 +0800 Fix flaky test --- .../src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java | 1 + 1 file changed, 1 insertion(+) 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 index 85c8eca8fa0..70c00558bf8 100644 --- 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 @@ -1683,6 +1683,7 @@ public class ReplicatorTest extends ReplicatorTestBase { MessageIdImpl lastMessageId = (MessageIdImpl) topic.getLastMessageId().get(); Position lastPosition = PositionImpl.get(lastMessageId.getLedgerId(), lastMessageId.getEntryId()); ConcurrentOpenHashMap<String, Replicator> replicators = topic.getReplicators(); + Awaitility.await().untilAsserted(() -> Assert.assertNotNull(replicators.get("r2"))); PersistentReplicator replicator = (PersistentReplicator) replicators.get("r2"); Awaitility.await().pollInterval(1, TimeUnit.SECONDS).timeout(30, TimeUnit.SECONDS)
