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 2b192b91ddf8b..91333441fff91 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 @@ -858,6 +858,7 @@ public ManagedCursor newNonDurableCursor(Position startCursorPosition, String cu NonDurableCursorImpl cursor = new NonDurableCursorImpl(bookKeeper, config, this, cursorName, (PositionImpl) startCursorPosition); + cursor.setActive(); log.info("[{}] Opened new cursor: {}", name, cursor); synchronized (this) { @@ -2894,7 +2895,7 @@ public void deactivateCursor(ManagedCursor cursor) { } public boolean isCursorActive(ManagedCursor cursor) { - return cursor.isDurable() && activeCursors.get(cursor.getName()) != null; + return activeCursors.get(cursor.getName()) != null; } private boolean currentLedgerIsFull() { diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorImpl.java index bc57f79c58c07..a0720d4348cdb 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorImpl.java @@ -92,21 +92,6 @@ protected void internalAsyncMarkDelete(final PositionImpl newPosition, Map