This is an automated email from the ASF dual-hosted git repository. chenhang pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 0a28b98a2370f8913ed5616f2e3c527878c7b00a Author: chenhang <[email protected]> AuthorDate: Tue Aug 16 15:25:43 2022 +0800 fix CI --- .../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java | 2 +- .../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java | 6 +++--- .../org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java | 3 ++- 3 files changed, 6 insertions(+), 5 deletions(-) diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java index 9b771a3301d..09a6fad2243 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java @@ -4053,7 +4053,7 @@ public class ManagedLedgerImpl implements ManagedLedger, CreateCallback { } public Position getTheSlowestNonDurationReadPosition() { - PositionImpl theSlowestNonDurableReadPosition = PositionImpl.LATEST; + PositionImpl theSlowestNonDurableReadPosition = PositionImpl.latest; for (ManagedCursor cursor : cursors) { if (cursor instanceof NonDurableCursorImpl) { PositionImpl readPosition = (PositionImpl) cursor.getReadPosition(); 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 527137eab29..c0b3d25af0c 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 @@ -3533,15 +3533,15 @@ public class ManagedLedgerTest extends MockedBookKeeperTestCase { positions.add(ledger.addEntry(("entry-" + i).getBytes(UTF_8))); } - Assert.assertEquals(ledger.getTheSlowestNonDurationReadPosition(), PositionImpl.LATEST); + Assert.assertEquals(ledger.getTheSlowestNonDurationReadPosition(), PositionImpl.latest); - ManagedCursor nonDurableCursor = ledger.newNonDurableCursor(PositionImpl.EARLIEST); + ManagedCursor nonDurableCursor = ledger.newNonDurableCursor(PositionImpl.earliest); Assert.assertEquals(ledger.getTheSlowestNonDurationReadPosition(), positions.get(0)); ledger.deleteCursor(nonDurableCursor.getName()); - Assert.assertEquals(ledger.getTheSlowestNonDurationReadPosition(), PositionImpl.LATEST); + Assert.assertEquals(ledger.getTheSlowestNonDurationReadPosition(), PositionImpl.latest); ledger.close(); } diff --git a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java index e0f8f459bff..18b09793e26 100644 --- a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java +++ b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorTest.java @@ -31,6 +31,7 @@ import com.google.common.collect.Iterables; import com.google.common.collect.Lists; import java.nio.charset.Charset; +import java.util.ArrayList; import java.util.List; import java.util.concurrent.CompletableFuture; import java.util.concurrent.CountDownLatch; @@ -742,7 +743,7 @@ public class NonDurableCursorTest extends MockedBookKeeperTestCase { new ManagedLedgerConfig().setMaxEntriesPerLedger(1).setRetentionTime(-1, TimeUnit.SECONDS) .setRetentionSizeInMB(-1)); ManagedCursor c1 = ledger.openCursor("c1"); - ManagedCursor nonDurableCursor = ledger.newNonDurableCursor(PositionImpl.EARLIEST); + ManagedCursor nonDurableCursor = ledger.newNonDurableCursor(PositionImpl.earliest); List<Position> positions = new ArrayList<>(); for (int i = 0; i < 10; i++) {
