File tree 1 file changed +3
-0
lines changed
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -3278,6 +3278,9 @@ private List<MLDataFormats.BatchedEntryDeletionIndexInfo> buildBatchEntryDeletio
3278
3278
Iterator <Map .Entry <PositionImpl , BitSetRecyclable >> iterator = batchDeletedIndexes .entrySet ().iterator ();
3279
3279
while (iterator .hasNext () && result .size () < getConfig ().getMaxBatchDeletedIndexToPersist ()) {
3280
3280
Map .Entry <PositionImpl , BitSetRecyclable > entry = iterator .next ();
3281
+ nestedPositionBuilder .setLedgerId (entry .getKey ().getLedgerId ());
3282
+ nestedPositionBuilder .setEntryId (entry .getKey ().getEntryId ());
3283
+ batchDeletedIndexInfoBuilder .setPosition (nestedPositionBuilder .build ());
3281
3284
long [] array = entry .getValue ().toLongArray ();
3282
3285
List <Long > deleteSet = new ArrayList <>(array .length );
3283
3286
for (long l : array ) {
You can’t perform that action at this time.
0 commit comments