This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.7 by this push:
new d2138f7 [Cursor] add return statement to exit asyncMarkDelete early
on failure (#10272)
d2138f7 is described below
commit d2138f7c4a84bc4d8b1d07600af15b30b7e2416e
Author: Michael Marshall <[email protected]>
AuthorDate: Tue Apr 20 11:26:24 2021 -0600
[Cursor] add return statement to exit asyncMarkDelete early on failure
(#10272)
(cherry picked from commit f489a92e36bb30ecd5b81b378b3305fc02b3db4e)
---
.../main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java | 1 +
1 file changed, 1 insertion(+)
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 4ff912f..f732a75 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
@@ -1605,6 +1605,7 @@ public class ManagedCursorImpl implements ManagedCursor {
new ManagedLedgerException("Reset cursor in progress -
unable to mark delete position "
+ position.toString()),
ctx);
+ return;
}
if (log.isDebugEnabled()) {
