Skip to content

Commit

Permalink
Increased timeout for ReplicatorTest to 90s
Browse files Browse the repository at this point in the history
  • Loading branch information
nikhil-ctds committed Mar 7, 2024
1 parent c3be263 commit 17e977c
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down

0 comments on commit 17e977c

Please sign in to comment.