(pulsar) branch branch-3.2 updated: [fix][test][branch-3.2] Fix DeduplicationDisabledBrokerLevelTest. Adjust to PR 22034 presence.

[lh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.2 by this push:
     new c2532b9741c [fix][test][branch-3.2] Fix DeduplicationDisabledBrokerLevelTest. Adjust to PR 22034 presence.
c2532b9741c is described below

commit c2532b9741c2ef34f88caf6c1440f447b5865eaa
Author: Lari Hotari <lh...@apache.org>
AuthorDate: Tue May 14 18:21:35 2024 +0300

    [fix][test][branch-3.2] Fix DeduplicationDisabledBrokerLevelTest. Adjust to PR 22034 presence.
---
 .../pulsar/broker/service/DeduplicationDisabledBrokerLevelTest.java   | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DeduplicationDisabledBrokerLevelTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DeduplicationDisabledBrokerLevelTest.java
index 11c93b180d0..2ce4ea9b00b 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DeduplicationDisabledBrokerLevelTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DeduplicationDisabledBrokerLevelTest.java
@@ -147,10 +147,8 @@ public class DeduplicationDisabledBrokerLevelTest extends ProducerConsumerBase {
         Awaitility.await().untilAsserted(() -> {
             int snapshotCounter3 = WhiteboxImpl.getInternalState(deduplication2, "snapshotCounter");
             assertTrue(snapshotCounter3 < brokerDeduplicationEntriesInterval);
-            // Since https://github.com/apache/pulsar/pull/22034 has not been cherry-pick into branch-3.0, there
-            // should be 2 ledgers.
             // Verify: the previous ledger will be removed because all messages have been acked.
-            assertEquals(ml2.getLedgersInfo().size(), 2);
+            assertEquals(ml2.getLedgersInfo().size(), 1);
         });
 
         // cleanup.