This is an automated email from the ASF dual-hosted git repository. technoboy pushed a commit to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 5fbc911ae380c6126e4d0150357d58315c09c20e Author: Michael Marshall <[email protected]> AuthorDate: Tue Aug 16 13:47:00 2022 -0500 [imp][managed-ledger] Optimize filterReadEntries usage of Entry interface ledger (#17108) --- .../java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java index 4c688b2d9be..78ec42b7183 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java @@ -2288,9 +2288,7 @@ public class ManagedCursorImpl implements ManagedCursor { } else { // Remove from the entry list all the entries that were already marked for deletion return Lists.newArrayList(Collections2.filter(entries, entry -> { - boolean includeEntry = !individualDeletedMessages.contains( - ((PositionImpl) entry.getPosition()).getLedgerId(), - ((PositionImpl) entry.getPosition()).getEntryId()); + boolean includeEntry = !individualDeletedMessages.contains(entry.getLedgerId(), entry.getEntryId()); if (!includeEntry) { if (log.isDebugEnabled()) { log.debug("[{}] [{}] Filtering entry at {} - already deleted", ledger.getName(), name,
