[fix][broker] Optimize code

Author: oneby-wang

managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java

@@ -2262,11 +2262,11 @@ public void asyncMarkDelete(final Position position, Map<String, Long> propertie
         boolean shouldCursorMoveForward = false;
         try {
             if (lastConfirmedEntry.getLedgerId() >= newPosition.getLedgerId()) {
-                LedgerInfo curMarkDeleteledgerInfo = ledger.getLedgerInfo(newPosition.getLedgerId()).get();
+                LedgerInfo curMarkDeleteLedgerInfo = ledger.getLedgerInfo(newPosition.getLedgerId()).get();
                 Long nextValidLedger = ledger.getNextValidLedger(newPosition.getLedgerId());
                 shouldCursorMoveForward = (nextValidLedger != null)
-                        && (curMarkDeleteledgerInfo != null
-                        && newPosition.getEntryId() + 1 >= curMarkDeleteledgerInfo.getEntries());
+                        && (curMarkDeleteLedgerInfo != null
+                        && newPosition.getEntryId() + 1 >= curMarkDeleteLedgerInfo.getEntries());
                 if (shouldCursorMoveForward) {
                     moveForwardPosition = PositionFactory.create(nextValidLedger, -1);
                 }

pulsar-broker/src/test/java/org/apache/pulsar/broker/service/MessageTTLTest.java

@@ -116,7 +116,7 @@ public void testMessageExpiryAfterTopicUnload() throws Exception {
             PersistentTopicInternalStats internalStatsAfterExpire = admin.topics().getInternalStats(topicName);
             CursorStats statsAfterExpire = internalStatsAfterExpire.cursors.get(subscriptionName);
             log.info("markDeletePosition after expire {}", statsAfterExpire.markDeletePosition);
-            // New ledger create, move markDeletePosition to currentLedgerId:-1
+            // New ledger created, move markDeletePosition to currentLedgerId:-1
             long currentLedgerId =
                     internalStatsAfterExpire.ledgers.get(internalStatsAfterExpire.ledgers.size() - 1).ledgerId;
             assertEquals(statsAfterExpire.markDeletePosition,

pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactedTopicTest.java

@@ -833,7 +833,7 @@ public void testReadCompactedLatestMessageWithInclusive() throws Exception {
             long ledgerId = ((MessageIdImpl) finalLastMessage).getLedgerId();
             long entryId = ((MessageIdImpl) finalLastMessage).getEntryId();
             Assert.assertEquals(stats.lastConfirmedEntry, PositionFactory.create(ledgerId, entryId).toString());
-            // New ledger create, move markDeletePosition to currentLedgerId:-1
+            // New ledger created, move markDeletePosition to currentLedgerId:-1
             long currentLedgerId = stats.ledgers.get(stats.ledgers.size() - 1).ledgerId;
             Assert.assertEquals(stats.cursors.get(COMPACTION_SUBSCRIPTION).markDeletePosition,
                     PositionFactory.create(currentLedgerId, -1).toString());