(pulsar) branch branch-3.0 updated: [fix][test][branch-3.0] Fix broken ManagedLedgerTest.testGetNumberOfEntriesInStorage

[lhotari]

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

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


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new e3531e808c1 [fix][test][branch-3.0] Fix broken 
ManagedLedgerTest.testGetNumberOfEntriesInStorage
e3531e808c1 is described below

commit e3531e808c172ff588e36499c41746835d06904a
Author: Lari Hotari <lhot...@apache.org>
AuthorDate: Thu Mar 28 12:14:23 2024 +0200

    [fix][test][branch-3.0] Fix broken 
ManagedLedgerTest.testGetNumberOfEntriesInStorage
    
    - change https://github.com/apache/pulsar/pull/22034 is missing from 
branch-3.0
---
 .../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java
 
b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java
index 10bfb699780..d20bbf0d7f5 100644
--- 
a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java
+++ 
b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java
@@ -2638,12 +2638,12 @@ public class ManagedLedgerTest extends 
MockedBookKeeperTestCase {
 
         // trigger ledger rollover and wait for the new ledger created
         Awaitility.await().untilAsserted(() -> {
-           assertEquals("LedgerOpened", 
WhiteboxImpl.getInternalState(managedLedger, "state").toString());
+           assertEquals(managedLedger.getState(), 
ManagedLedgerImpl.State.ClosedLedger);
         });
         managedLedger.rollCurrentLedgerIfFull();
         Awaitility.await().untilAsserted(() -> {
-            assertEquals(managedLedger.getLedgersInfo().size(), 3);
-            assertEquals(managedLedger.getState(), 
ManagedLedgerImpl.State.LedgerOpened);
+            assertEquals(managedLedger.getLedgersInfo().size(), 2);
+            assertEquals(managedLedger.getState(), 
ManagedLedgerImpl.State.ClosedLedger);
         });
         assertEquals(5, 
managedLedger.getLedgersInfoAsList().get(0).getEntries());
         assertEquals(5, 
managedLedger.getLedgersInfoAsList().get(1).getEntries());