Skip to content

Commit

Permalink
Added new line
Browse files Browse the repository at this point in the history
  • Loading branch information
nikhil-ctds committed Mar 7, 2024
1 parent c4ff7b9 commit be7d9a1
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1707,6 +1707,7 @@ public void testReplicatorWithFailedAck() throws Exception {
Awaitility.await().pollInterval(1, TimeUnit.SECONDS).timeout(30, 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);

// Make sure all the data has replicated to the remote cluster before close the cursor.
Expand Down

0 comments on commit be7d9a1

Please sign in to comment.