Skip to content

Commit

Permalink
[fix][broker] ManagedCursor: mark delete no callback when create meta…
Browse files Browse the repository at this point in the history
…-ledger fail (#16841)

(cherry picked from commit 5faac76)
  • Loading branch information
poorbarcode authored and Jason918 committed Jul 29, 2022
1 parent 10b4e99 commit 25a1098
Showing 1 changed file with 3 additions and 1 deletion.
Expand Up @@ -1703,8 +1703,10 @@ protected void internalAsyncMarkDelete(final PositionImpl newPosition, Map<Strin
return;

case NoLedger:
// We need to create a new ledger to write into
pendingMarkDeleteOps.add(mdEntry);
// We need to create a new ledger to write into.
startCreatingNewMetadataLedger();
break;
// fall through
case SwitchingLedger:
pendingMarkDeleteOps.add(mdEntry);
Expand Down

0 comments on commit 25a1098

Please sign in to comment.