improve the comment for test

apache · Aug 21, 2024 · b6283f9 · b6283f9
1 parent 436d0cd
commit b6283f9
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...c/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerMLInitializeDelayTest.java b/...c/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerMLInitializeDelayTest.java
@@ -125,8 +125,7 @@ public void testConcurrentlyOfPublishAndSwitchLedger() throws Exception {
         ManagedLedgerConfig config = persistentTopic.getManagedLedger().getConfig();
         config.setMaxEntriesPerLedger(2);
         config.setMinimumRolloverTime(0, TimeUnit.MILLISECONDS);
-        // Inject a delay for the initialization of ML, to make the consumer to register twice.
-        // Consumer register twice: the first will be timeout, and try again.
+        // Inject a delay for switching ledgers, so publishing requests will be push in to the pending queue.
         AtomicInteger delayTimes = new AtomicInteger();
         mockZooKeeper.delay(10, (op, s) -> {
             if (op.toString().equals("SET") && s.contains(TopicName.get(topicName).getPersistenceNamingEncoding())) {