Skip to content

Commit

Permalink
Fix unit test
Browse files Browse the repository at this point in the history
  • Loading branch information
codelipenghui committed Jan 31, 2020
1 parent afafd56 commit 51f599e
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1506,9 +1506,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 51f599e

Please sign in to comment.