File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -2663,7 +2663,6 @@ public void testGetNumberOfEntriesInStorage() throws Exception {
26632663 @ Test
26642664 public void testGetNumberOfEntries () throws Exception {
26652665 ManagedLedgerConfig managedLedgerConfig = new ManagedLedgerConfig ();
2666- initManagedLedgerConfig (managedLedgerConfig );
26672666 managedLedgerConfig .setMaxEntriesPerLedger (5 );
26682667 ManagedLedgerImpl managedLedger =
26692668 (ManagedLedgerImpl ) factory .open ("testGetNumberOfEntries" , managedLedgerConfig );
@@ -2674,8 +2673,8 @@ public void testGetNumberOfEntries() throws Exception {
26742673 for (int i = 0 ; i < numberOfEntries ; i ++) {
26752674 positions .add (managedLedger .addEntry (("entry-" + i ).getBytes (Encoding )));
26762675 }
2677- Position mdPos = positions .get (numberOfEntries - 1 );
2678- Position rdPos = PositionFactory . create (mdPos .getLedgerId (), mdPos .getEntryId () + 1 );
2676+ PositionImpl mdPos = ( PositionImpl ) positions .get (numberOfEntries - 1 );
2677+ PositionImpl rdPos = PositionImpl . get (mdPos .getLedgerId (), mdPos .getEntryId () + 1 );
26792678 managedCursor .delete (positions );
26802679 // trigger ledger rollover and wait for the new ledger created
26812680 Awaitility .await ().untilAsserted (() -> {
You can’t perform that action at this time.
0 commit comments