lhotari opened a new issue #9762:
URL: https://github.com/apache/pulsar/issues/9762
**Describe the bug**
Occasionally I have seen this kind of NPE in the logs when running
ReplicatorTest locally:
```
java.lang.NullPointerException: null
at
org.apache.pulsar.broker.service.persistent.PersistentReplicator.updateCursorState(PersistentReplicator.java:447)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$updateRates$44(PersistentTopic.java:1490)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.updateRates(PersistentTopic.java:1487)
~[classes/:?]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$1(PulsarStats.java:132)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$3(PulsarStats.java:129)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$updateStats$4(PulsarStats.java:118)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.updateStats(PulsarStats.java:108)
~[classes/:?]
at
org.apache.pulsar.broker.service.BrokerService.updateRates(BrokerService.java:1402)
~[classes/:?]
```
and
```
java.lang.NullPointerException: null
at
org.apache.pulsar.broker.service.persistent.PersistentReplicator.getStats(PersistentReplicator.java:691)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$updateRates$44(PersistentTopic.java:1497)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.updateRates(PersistentTopic.java:1487)
~[classes/:?]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$1(PulsarStats.java:132)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$3(PulsarStats.java:129)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$updateStats$4(PulsarStats.java:118)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.updateStats(PulsarStats.java:108)
~[classes/:?]
at
org.apache.pulsar.broker.service.BrokerService.updateRates(BrokerService.java:1402)
~[classes/:?]
```
<details>
<summary>More log lines around exception</summary>
<code><pre>
09:10:41.664 [pulsar-io-219-1] INFO
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x4ec03f82,
L:/127.0.0.1:47540 - R:localhost/127.0.0.1:41495]] Connected to server
09:10:41.665 [BookKeeperClientWorker-OrderedExecutor-0-0] INFO
org.apache.bookkeeper.mledger.impl.MetaStoreImpl -
[pulsar/ns/persistent/topic-2-90c910fb-c913-4377-bf63-f5b5cc34df1c]
[pulsar.repl.r2] Updating cursor info ledgerId=17 mark-delete=7:-1
09:10:41.665 [bookkeeper-ml-workers-OrderedExecutor-0-0] INFO
org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl -
[pulsar/ns/persistent/topic-8-5498c3d0-f02d-4c22-ab27-6a189b017775]
Successfully initialize managed ledger
09:10:41.577 [pulsar-stats-updater-60-1] WARN
org.apache.pulsar.broker.service.persistent.PersistentTopic -
[persistent://pulsar/ns/topic-6-a4e2e8dd-3841-4655-807f-516ba81ba050] Failed to
update cursro state
java.lang.NullPointerException: null
at
org.apache.pulsar.broker.service.persistent.PersistentReplicator.updateCursorState(PersistentReplicator.java:447)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$updateRates$44(PersistentTopic.java:1490)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.updateRates(PersistentTopic.java:1487)
~[classes/:?]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$1(PulsarStats.java:132)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$3(PulsarStats.java:129)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$updateStats$4(PulsarStats.java:118)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.updateStats(PulsarStats.java:108)
~[classes/:?]
at
org.apache.pulsar.broker.service.BrokerService.updateRates(BrokerService.java:1402)
~[classes/:?]
at
org.apache.bookkeeper.mledger.util.SafeRun$1.safeRun(SafeRun.java:32)
[managed-ledger-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36)
[bookkeeper-common-4.12.1.jar:4.12.1]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_275]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
[?:1.8.0_275]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[?:1.8.0_275]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[?:1.8.0_275]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_275]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_275]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[netty-common-4.1.51.Final.jar:4.1.51.Final]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
09:10:41.665 [bookkeeper-ml-workers-OrderedExecutor-0-0] INFO
org.apache.pulsar.broker.service.AbstractTopic - Disabling publish throttling
for persistent://pulsar/ns/topic-8-5498c3d0-f02d-4c22-ab27-6a189b017775
09:10:41.665 [pulsar-io-59-2] INFO
org.apache.pulsar.broker.service.ServerCnx - New connection from
/127.0.0.1:47540
09:10:41.665 [bookkeeper-ml-workers-OrderedExecutor-0-0] WARN
org.apache.pulsar.broker.service.BrokerService - Topic level policies are not
enabled. Please refer to systemTopicEnabled and topicLevelPoliciesEnabled on
broker.conf
09:10:41.666 [BookKeeperClientWorker-OrderedExecutor-0-0] INFO
org.apache.bookkeeper.mledger.impl.MetaStoreImpl -
[pulsar/ns/persistent/topic-6-a4e2e8dd-3841-4655-807f-516ba81ba050]
[pulsar.repl.r3] Updating cursor info ledgerId=37 mark-delete=33:-1
09:10:41.666 [Thread-45] INFO org.apache.pulsar.broker.service.ServerCnx -
[/127.0.0.1:47492]
persistent://pulsar/ns/topic-7-be3023df-a3b8-4e51-9bbf-bd5719ebafd8 configured
with schema false
09:10:41.666 [bookkeeper-ml-workers-OrderedExecutor-0-0] INFO
org.apache.pulsar.broker.service.persistent.PersistentTopic -
[persistent://pulsar/ns/topic-8-5498c3d0-f02d-4c22-ab27-6a189b017775] There are
no replicated subscriptions on the topic
09:10:41.666 [bookkeeper-ml-workers-OrderedExecutor-0-0] INFO
org.apache.pulsar.broker.service.persistent.PersistentTopic -
[persistent://pulsar/ns/topic-8-5498c3d0-f02d-4c22-ab27-6a189b017775] Starting
replicator to remote: r2
09:10:41.666 [BookKeeperClientWorker-OrderedExecutor-0-0] INFO
org.apache.bookkeeper.mledger.impl.MetaStoreImpl -
[pulsar/ns/persistent/topic-7-be3023df-a3b8-4e51-9bbf-bd5719ebafd8]
[pulsar.repl.r2] Updating cursor info ledgerId=39 mark-delete=34:-1
09:10:41.665 [pulsar-stats-updater-60-1] ERROR
org.apache.pulsar.broker.service.PulsarStats - Failed to generate topic stats
for topic persistent://pulsar/ns/topic-6-a4e2e8dd-3841-4655-807f-516ba81ba050:
null
java.lang.NullPointerException: null
at
org.apache.pulsar.broker.service.persistent.PersistentReplicator.getStats(PersistentReplicator.java:691)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$updateRates$44(PersistentTopic.java:1497)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.updateRates(PersistentTopic.java:1487)
~[classes/:?]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$1(PulsarStats.java:132)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$3(PulsarStats.java:129)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$updateStats$4(PulsarStats.java:118)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.updateStats(PulsarStats.java:108)
~[classes/:?]
at
org.apache.pulsar.broker.service.BrokerService.updateRates(BrokerService.java:1402)
~[classes/:?]
at
org.apache.bookkeeper.mledger.util.SafeRun$1.safeRun(SafeRun.java:32)
[managed-ledger-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36)
[bookkeeper-common-4.12.1.jar:4.12.1]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_275]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
[?:1.8.0_275]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[?:1.8.0_275]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[?:1.8.0_275]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_275]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_275]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[netty-common-4.1.51.Final.jar:4.1.51.Final]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
09:10:41.667 [TestNG-method=setup-1-EventThread] INFO
org.apache.bookkeeper.client.LedgerCreateOp - Ensemble: [127.0.1.1:32829,
127.0.1.1:40497] for ledger: 27
09:10:41.667 [Thread-46] INFO org.apache.pulsar.broker.service.ServerCnx -
[/127.0.0.1:47518]
persistent://pulsar/ns/topic-1-f06f789b-7978-4b9d-88a2-223497e63d90 configured
with schema false
09:10:41.667 [pulsar-io-219-1] INFO
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x8bdb8c82,
L:/127.0.0.1:47542 - R:localhost/127.0.0.1:41495]] Connected to server
09:10:41.759 [pulsar-io-219-2] INFO
org.apache.pulsar.client.impl.ProducerImpl -
[persistent://pulsar/ns/topic-0-c42ada08-5151-4441-b183-841bf6b92731]
[pulsar.repl.r3] Creating producer on cnx [id: 0x4ec03f82, L:/127.0.0.1:47540 -
R:localhost/127.0.0.1:41495]
09:10:41.761 [pulsar-io-219-2] INFO
org.apache.pulsar.client.impl.ProducerImpl -
[persistent://pulsar/ns/topic-4-39654655-940c-4d6c-a026-4317dcd4be4b]
[pulsar.repl.r3] Creating producer on cnx [id: 0x7758fc61, L:/127.0.0.1:47536 -
R:localhost/127.0.0.1:41495]
09:10:41.762 [pulsar-io-219-1] INFO
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x0fe115c9,
L:/127.0.0.1:48302 - R:localhost/127.0.0.1:34531]] Connected to server
09:10:41.759 [Thread-47] INFO org.apache.pulsar.broker.service.ServerCnx -
[/127.0.0.1:47524]
persistent://pulsar/ns/topic-3-93d39626-55e5-430a-b4e4-9129ffe0e09f configured
with schema false
09:10:41.667 [pulsar-stats-updater-60-1] WARN
org.apache.pulsar.broker.service.persistent.PersistentTopic -
[persistent://pulsar/ns/topic-7-be3023df-a3b8-4e51-9bbf-bd5719ebafd8] Failed to
update cursro state
java.lang.NullPointerException: null
at
org.apache.pulsar.broker.service.persistent.PersistentReplicator.updateCursorState(PersistentReplicator.java:447)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$updateRates$44(PersistentTopic.java:1490)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.updateRates(PersistentTopic.java:1487)
~[classes/:?]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$1(PulsarStats.java:132)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$3(PulsarStats.java:129)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$updateStats$4(PulsarStats.java:118)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.updateStats(PulsarStats.java:108)
~[classes/:?]
at
org.apache.pulsar.broker.service.BrokerService.updateRates(BrokerService.java:1402)
~[classes/:?]
at
org.apache.bookkeeper.mledger.util.SafeRun$1.safeRun(SafeRun.java:32)
[managed-ledger-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36)
[bookkeeper-common-4.12.1.jar:4.12.1]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_275]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
[?:1.8.0_275]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[?:1.8.0_275]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[?:1.8.0_275]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_275]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_275]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[netty-common-4.1.51.Final.jar:4.1.51.Final]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
09:10:41.763 [TestNG-method=setup-1-EventThread] INFO
org.apache.bookkeeper.client.LedgerCreateOp - Ensemble: [127.0.1.1:38403,
127.0.1.1:32917] for ledger: 18
09:10:41.761 [TestNG-method=setup-1-EventThread] INFO
org.apache.bookkeeper.client.LedgerCreateOp - Ensemble: [127.0.1.1:43249,
127.0.1.1:40221] for ledger: 41
09:10:41.763 [pulsar-stats-updater-60-1] ERROR
org.apache.pulsar.broker.service.PulsarStats - Failed to generate topic stats
for topic persistent://pulsar/ns/topic-7-be3023df-a3b8-4e51-9bbf-bd5719ebafd8:
null
java.lang.NullPointerException: null
at
org.apache.pulsar.broker.service.persistent.PersistentReplicator.getStats(PersistentReplicator.java:691)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$updateRates$44(PersistentTopic.java:1497)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.updateRates(PersistentTopic.java:1487)
~[classes/:?]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$1(PulsarStats.java:132)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$null$3(PulsarStats.java:129)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.lambda$updateStats$4(PulsarStats.java:118)
~[classes/:?]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
~[pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.pulsar.broker.service.PulsarStats.updateStats(PulsarStats.java:108)
~[classes/:?]
at
org.apache.pulsar.broker.service.BrokerService.updateRates(BrokerService.java:1402)
~[classes/:?]
at
org.apache.bookkeeper.mledger.util.SafeRun$1.safeRun(SafeRun.java:32)
[managed-ledger-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
at
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36)
[bookkeeper-common-4.12.1.jar:4.12.1]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_275]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
[?:1.8.0_275]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[?:1.8.0_275]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[?:1.8.0_275]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_275]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(T^ChreadPoolExecutor.java:624)
[?:1.8.0_275]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[netty-common-4.1.51.Final.jar:4.1.51.Final]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
</pre></code>
</details>
----------------------------------------------------------------
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:
[email protected]
