From be7d9a1bf8590db514b9a1769ff61cc20286e5ab Mon Sep 17 00:00:00 2001 From: nikhil-ctds Date: Thu, 7 Mar 2024 12:48:39 +0530 Subject: [PATCH] Added new line --- .../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 47509406816c7..35c4705ff3e3f 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 @@ -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.