From 17e977c72930b46a748309ec23cb57b05bc7036d Mon Sep 17 00:00:00 2001
From: nikhil-ctds <ext-nikhil.erigila@datastax.com>
Date: Thu, 7 Mar 2024 20:14:09 +0530
Subject: [PATCH] Increased timeout for ReplicatorTest to 90s

---
 .../java/org/apache/pulsar/broker/service/ReplicatorTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 2ea88c77fbebe..c2e2de8e8144f 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
@@ -1704,7 +1704,7 @@ public void testReplicatorWithFailedAck() throws Exception {
         ConcurrentOpenHashMap<String, Replicator> replicators = topic.getReplicators();
         PersistentReplicator replicator = (PersistentReplicator) replicators.get("r2");
 
-        Awaitility.await().pollInterval(1, TimeUnit.SECONDS).timeout(60, TimeUnit.SECONDS)
+        Awaitility.await().pollInterval(1, TimeUnit.SECONDS).timeout(90, TimeUnit.SECONDS)
                 .untilAsserted(() -> assertEquals(org.apache.pulsar.broker.service.AbstractReplicator.State.Started,
                         replicator.getState()));
         assertEquals(replicator.getState(), org.apache.pulsar.broker.service.AbstractReplicator.State.Started);