Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Bug] checkBacklogQuota NullPointerException #23735

Open
2 of 3 tasks
KannarFr opened this issue Dec 16, 2024 · 5 comments
Open
2 of 3 tasks

[Bug] checkBacklogQuota NullPointerException #23735

KannarFr opened this issue Dec 16, 2024 · 5 comments
Labels
type/bug The PR fixed a bug or issue reported a bug

Comments

@KannarFr
Copy link
Contributor

KannarFr commented Dec 16, 2024 •
edited
Loading

Search before asking

  • I searched in the issues and found nothing similar.

Read release policy

  • I understand that unsupported versions don't get bug fixes. I will attempt to reproduce the issue on a supported version of Pulsar client and Pulsar broker.

Version

4.0.1

Minimal reproduce step

/

What did you expect to see?

Nothing

What did you see instead?

Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]: 2024-12-16T11:25:35,145+0000 [pulsar-backlog-quota-checker-OrderedScheduler-0-0] ERROR org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://orga_2b5d63f2-610f-4f14-8d4e-7ede8fb3a77a/logs/__change_events-partition-0][java.lang.NullPointerException] Error reading entry for update old position
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]: 2024-12-16T11:25:35,145+0000 [pulsar-backlog-quota-checker-OrderedScheduler-0-0] ERROR org.apache.pulsar.broker.service.BrokerService - Error when checkBacklogQuota(persistent://orga_2b5d63f2-610f-4f14-8d4e-7ede8fb3a77a/logs/__change_events-partition-0) in monitorBacklogQuota
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]: java.util.concurrent.CompletionException: java.lang.NullPointerException
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:332) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.concurrent.CompletableFuture.uniAcceptNow(CompletableFuture.java:747) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:735) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2214) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at org.apache.pulsar.broker.service.BrokerService.lambda$monitorBacklogQuota$111(BrokerService.java:2248) ~[org.apache.pulsar-pulsar-broker-4.0.1.jar:4.0.1]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at org.apache.pulsar.broker.service.BrokerService.lambda$forEachPersistentTopic$106(BrokerService.java:2238) ~[org.apache.pulsar-pulsar-broker-4.0.1.jar:4.0.1]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.Optional.ifPresent(Optional.java:178) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at org.apache.pulsar.broker.service.BrokerService.lambda$forEachPersistentTopic$107(BrokerService.java:2238) ~[org.apache.pulsar-pulsar-broker-4.0.1.jar:4.0.1]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.concurrent.ConcurrentHashMap$ValueSpliterator.forEachRemaining(ConcurrentHashMap.java:3612) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at org.apache.pulsar.broker.service.BrokerService.forEachPersistentTopic(BrokerService.java:2238) ~[org.apache.pulsar-pulsar-broker-4.0.1.jar:4.0.1]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at org.apache.pulsar.broker.service.BrokerService.monitorBacklogQuota(BrokerService.java:2247) ~[org.apache.pulsar-pulsar-broker-4.0.1.jar:4.0.1]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at com.google.common.util.concurrent.MoreExecutors$ScheduledListeningDecorator$NeverSuccessfulListenableFutureTask.run(MoreExecutors.java:741) ~[com.google.guava-guava-32.1.2-jre.jar:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at org.apache.bookkeeper.common.util.SingleThreadSafeScheduledExecutorService$SafeRunnable.run(SingleThreadSafeScheduledExecutorService.java:46) ~[org.apache.bookkeeper-bookkeeper-common-4.17.1.jar:4.17.1]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.netty-netty-common-4.1.115.Final.jar:4.1.115.Final]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]:        at java.base/java.lang.Thread.run(Thread.java:1583) [?:?]
Dec 16 11:25:35 yo-pulsar-broker-c3-n4 pulsar[3729204]: Caused by: java.lang.NullPointerException

Anything else?

No response

Are you willing to submit a PR?

  • I'm willing to submit a PR!
@KannarFr KannarFr added the type/bug The PR fixed a bug or issue reported a bug label Dec 16, 2024
@KannarFr KannarFr mentioned this issue Dec 16, 2024
Open
3 tasks
@dao-jun
Copy link
Member

dao-jun commented Dec 16, 2024

can you please provide more related logs?

@lhotari
Copy link
Member

lhotari commented Dec 16, 2024

I wonder if this is fixed by #23720?

@KannarFr
Copy link
Contributor Author

@dao-jun I have no more related logs.

@lhotari it looks like yes.

Also, apparently it only occurs on __change_events-partiton-0 topics.

@lhotari
Copy link
Member

lhotari commented Dec 16, 2024 •
edited
Loading

@KannarFr Is this also related to #23294?

@KannarFr
Copy link
Contributor Author

KannarFr commented Dec 17, 2024 •
edited
Loading

@lhotari yes but not exactly the same exception.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
type/bug The PR fixed a bug or issue reported a bug
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
3 participants
@lhotari @KannarFr @dao-jun