[GitHub] [pulsar] codelipenghui edited a comment on issue #7941: Consumer can't get messages with earliest position subscription type under some circumstances

[GitBox <gi...@apache.org>]

codelipenghui edited a comment on issue #7941:
URL: https://github.com/apache/pulsar/issues/7941#issuecomment-689439210


   @alexku7 I have tested on my laptop, but the error information looks a bit different
   
   ```
   java.lang.IndexOutOfBoundsException: Index -125 out of bounds for length 5
           at jdk.internal.util.Preconditions.outOfBounds(Preconditions.java:64) ~[?:?]
           at jdk.internal.util.Preconditions.outOfBoundsCheckIndex(Preconditions.java:70) ~[?:?]
           at jdk.internal.util.Preconditions.checkIndex(Preconditions.java:248) ~[?:?]
           at java.util.Objects.checkIndex(Objects.java:372) ~[?:?]
           at java.util.ArrayList.get(ArrayList.java:458) ~[?:?]
           at org.apache.pulsar.broker.service.persistent.PersistentStickyKeyDispatcherMultipleConsumers.sendMessagesToConsumers(PersistentStickyKeyDispatcherMultipleConsumers.java:173) ~[org.apache.pulsar-pulsar-broker-2.6.1.jar:2.6.1]
           at org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers.readEntriesComplete(PersistentDispatcherMultipleConsumers.java:480) ~[org.apache.pulsar-pulsar-broker-2.6.1.jar:2.6.1]
           at org.apache.bookkeeper.mledger.impl.OpReadEntry.lambda$checkReadCompletion$2(OpReadEntry.java:152) ~[org.apache.pulsar-managed-ledger-2.6.1.jar:2.6.1]
           at org.apache.bookkeeper.mledger.util.SafeRun$1.safeRun(SafeRun.java:32) ~[org.apache.pulsar-managed-ledger-2.6.1.jar:2.6.1]
           at org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36) [org.apache.bookkeeper-bookkeeper-common-4.10.0.jar:4.10.0]
           at org.apache.bookkeeper.common.util.OrderedExecutor$TimedRunnable.run(OrderedExecutor.java:203) [org.apache.bookkeeper-bookkeeper-common-4.10.0.jar:4.10.0]
           at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
           at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
           at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [io.netty-netty-common-4.1.48.Final.jar:4.1.48.Final]
           at java.lang.Thread.run(Thread.java:834) [?:?]
   ```
   
   Could you please help verify without message batching? I suspect to the batch message and I have verified on my laptop(2.6.1). So I can confirm if they are the same issue.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org