Skip to content

Commit

Permalink
Fix unit test
Browse files Browse the repository at this point in the history
  • Loading branch information
codelipenghui committed Feb 13, 2020
1 parent 5202a16 commit 201bc3e
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1513,9 +1513,9 @@ public void asyncMarkDelete(final Position position, Map<String, Long> propertie
if (config.isBatchIndexDeleteEnabled()) {
if (newPosition.ackSet != null) {
batchDeletedIndexes.put(newPosition, newPosition.ackSet);
newPosition = ledger.getPreviousPosition(newPosition);
}
batchDeletedIndexes.subMap(PositionImpl.earliest, newPosition).clear();
newPosition = ledger.getPreviousPosition(newPosition);
} else if (newPosition.ackSet != null) {
callback.markDeleteFailed(new ManagedLedgerException("Batch ack set not support"), ctx);
return;
Expand Down

0 comments on commit 201bc3e

Please sign in to comment.