kaushik-develop opened a new issue #11523:
URL: https://github.com/apache/pulsar/issues/11523
**Describe the bug**
Null pointer exception was encountered in newMessageAndIntercept, in our
internal deployment.
**To Reproduce**
The exact reproduction steps are not known at this point. The issue was
observed in a scaled-out environment.
The stack-trace is as shown below (off a 2.7 based Pulsar deployment).
{"instant":{"epochSecond":1626043491,"nanoOfSecond":307589000},"thread":"pulsar-io-28-11","level":"ERROR","loggerName":"org.apache.pulsar.broker.service.ServerCnx","message":"Exception
occur when intercept me
ssages.","thrown":{"commonElementCount":0,"name":"java.lang.NullPointerException","extendedStackTrace":"java.lang.NullPointerException:
null\n\tat org.apache.pulsar.broker.service.ServerCnx.newMessageAndInter
cept(ServerCnx.java:2175)
~[org.apache.pulsar-pulsar-broker-2.7.0.XXXX.NNNNNNNN.jar:2.7.0.XXXX.NNNNNNNN]\n\tat
org.apache.pulsar.broker.service.PulsarCommandSenderImpl.lambda$sendMessagesToConsumer$0(PulsarCo
mmandSenderImpl.java:265)
~[org.apache.pulsar-pulsar-broker-2.7.0.XXXX.NNNNNNNN.jar:2.7.0.XXXX.NNNNNNNN]\n\tat
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
[io.ne tty-netty-common-4.1.60.Final.jar:4.1.60.Final]\n\tat
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasksFrom(SingleThreadEventExecutor.java:428)
[i
o.netty-netty-common-4.1.60.Final.jar:4.1.60.Fina l]\n\tat
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:377)
[io.netty-netty-common-4.1.60.Final.jar:4.1.60.Final]\n\tat
io.netty.util.concurrent.SingleThreadEve
ntExecutor.confirmShutdown(SingleThreadEventExecutor.java:763)
[io.netty-netty-common-4.1.60.Final.jar:4.1.60.Final]\n\tat
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:402)
[io.netty-netty-tr ansport-native-epoll-4.1.60.Final.jar:4.1.60.Final]\n\tat
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
[io.netty-netty-common-4.1.60.Final.jar:4.1.60.Final]\n\t at
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
[io.netty-netty-common-4.1.60.Final.jar:4.1.60.Final]\n\tat
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRun
nable.java:30) [io.netty-netty-common-4.1.60.Final.jar:4.1.60.Final]\n\tat
java.lang.Thread.run(Thread.java:834
)
[?:?]\n"},"endOfBatch":false,"loggerFqcn":"org.apache.logging.slf4j.Log4jLogger","contextMap":{
},"threadId":228,"threadPriority":5,"time":"2021-07-11T21:35:03Z","service":"pulsar","hostname":"broker-2"}
**Expected behavior**
The code should not de-ref a null pointer.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
