From ea7913fc3298a8e5de8da6f5d757467c094589f7 Mon Sep 17 00:00:00 2001 From: gavingaozhangmin Date: Mon, 9 Jan 2023 14:51:30 +0800 Subject: [PATCH] Use cursor.isActive condition instead --- .../org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 7b8fdf1f816fa..cf10929738903 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 @@ -3663,7 +3663,7 @@ Pair getFirstPositionAndCounter() { public void activateCursor(ManagedCursor cursor) { synchronized (activeCursors) { - if (activeCursors.get(cursor.getName()) == null) { + if (!cursor.isActive()) { Position positionForOrdering = config.isCacheEvictionByMarkDeletedPosition() ? cursor.getMarkDeletedPosition() : cursor.getReadPosition();