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 (apache#16841)

(cherry picked from commit 5faac76)
  • Loading branch information
poorbarcode authored and codelipenghui committed Aug 8, 2022
1 parent 72af22c commit 86ceb3f
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1860,8 +1860,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 86ceb3f

Please sign in to comment.