Skip to content

Commit

Permalink
Fix IndexOutOfBoundsException in PersistentDispatcherMultipleConsumers
Browse files Browse the repository at this point in the history
This error is due to the resolution of a conflict while committing bfa30dd

java.lang.IndexOutOfBoundsException: toIndex = 76
2021-10-28T17:06:02,977 [bookkeeper-ml-workers-OrderedExecutor-5-0] WARN  org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [omg/post-book-resp-event-consumer/persistent/post-book-response-event-REPLAY][post-book-response-event-consumer-replay] Error while replaying entries
org.apache.bookkeeper.mledger.ManagedLedgerException: Other exception
Caused by: java.lang.IndexOutOfBoundsException: toIndex = 76
Oct 28 13:06:02 ocdataeng06 0cc94feb3fc7: 2021-10-28T17:06:02,979 [main-EventThread] INFO  org.apache.bookkeeper.meta.ZkLedgerUnderreplicationManager - Latch countdown due to ZK event: WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/ledgers/underreplication/ledgers/0000/0000
  • Loading branch information
eolivelli committed Oct 29, 2021
1 parent 4c58e27 commit e9f5982
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -553,7 +553,7 @@ protected void sendMessagesToConsumers(ReadType readType, List<Entry> entries) {
int end = Math.min(start + messagesForC, entries.size());
// remove positions first from replay list first : sendMessages recycles entries
if (readType == ReadType.Replay) {
entries.subList(start, start + messagesForC).forEach(entry -> {
entries.subList(start, end).forEach(entry -> {
redeliveryMessages.remove(entry.getLedgerId(), entry.getEntryId());
});
}
Expand Down

0 comments on commit e9f5982

Please sign in to comment.