[fix] [broker] Msg delivery is stuck due to items in the collection recentlyJoinedConsumers are out-of-order #22393
Annotations
2 errors and 2 warnings
|
Run unit test group 'BROKER_CLIENT_IMPL'
Process completed with exit code 1.
|
|
Publish Test Report:
pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java#L2068
--- An unexpected error occurred in the server ---
Message: org.apache.bookkeeper.mledger.ManagedLedgerException$MetaStoreException: java.lang.NullPointerException: Cannot invoke "java.util.Map.size()" because "m" is null
Stacktrace:
org.apache.pulsar.broker.service.BrokerServiceException$PersistenceException: org.apache.bookkeeper.mledger.ManagedLedgerException$MetaStoreException: java.lang.NullPointerException: Cannot invoke "java.util.Map.size()" because "m" is null
at org.apache.pulsar.broker.service.persistent.PersistentTopic$5.deleteCursorFailed(PersistentTopic.java:1368)
at org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl$7.operationFailed(ManagedLedgerImpl.java:1076)
at org.apache.bookkeeper.mledger.impl.MetaStoreImpl.lambda$asyncRemoveCursor$20(MetaStoreImpl.java:296)
at org.apache.bookkeeper.common.util.OrderedExecutor$TimedRunnable.run(OrderedExecutor.java:203)
at org.apache.bookkeeper.common.util.SingleThreadSafeScheduledExecutorService$SafeRunnable.run(SingleThreadSafeScheduledExecutorService.java:46)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: org.apache.bookkeeper.mledger.ManagedLedgerException$MetaStoreException: java.lang.NullPointerException: Cannot invoke "java.util.Map.size()" because "m" is null
Caused by: java.lang.NullPointerException: Cannot invoke "java.util.Map.size()" because "m" is null
at java.base/java.util.HashMap.putMapEntries(HashMap.java:503)
at java.base/java.util.LinkedHashMap.<init>(LinkedHashMap.java:480)
at org.apache.pulsar.broker.service.persistent.PersistentStickyKeyDispatcherMultipleConsumersClassic.getRecentlyJoinedConsumers(PersistentStickyKeyDispatcherMultipleConsumersClassic.java:597)
at org.apache.pulsar.broker.service.persistent.PersistentSubscription.getStatsAsync(PersistentSubscription.java:1337)
at org.apache.pulsar.broker.service.persistent.PersistentTopic.removeSubscription(PersistentTopic.java:1378)
at org.apache.pulsar.broker.service.persistent.PersistentTopic$5.deleteCursorComplete(PersistentTopic.java:1352)
at org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl$7.operationComplete(ManagedLedgerImpl.java:1070)
at org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl$7.operationComplete(ManagedLedgerImpl.java:1060)
at org.apache.bookkeeper.mledger.impl.MetaStoreImpl.lambda$asyncRemoveCursor$19(MetaStoreImpl.java:286)
at java.base/java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:718)
at java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
at org.apache.bookkeeper.common.util.OrderedExecutor$TimedRunnable.run(OrderedExecutor.java:203)
at org.apache.bookkeeper.common.util.SingleThreadSafeScheduledExecutorService$SafeRunnable.run(SingleThreadSafeScheduledExecutorService.java:46)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:1583)
|
|
Report detected thread leaks
Summary: Tests in class org.apache.pulsar.client.impl.ProduceWithMessageIdTest created 68 new threads. There are now 77 threads in total.
|
|
Report detected thread leaks
Summary: Tests in class org.apache.pulsar.client.impl.ReaderTest created 8 new threads. There are now 17 threads in total.
|
Loading