lhotari opened a new issue #9760:
URL: https://github.com/apache/pulsar/issues/9760


   **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.client.impl.ClientCnx.lambda$sendRequestAndHandleTimeout$12(ClientCnx.java:858)
 ~[pulsar-client-original-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
           at 
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577)
 [netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:551)
 [netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:490)
 [netty-common-4.1.51.Final.jar:4.1.51.Final]
   ```
   
   <details>
   <summary>More log lines around exception</summary>
   <code><pre>
   12:42:35.971 [pulsar-io-59-1] INFO  
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x13a67ea1, 
L:/127.0.0.1:37514 - R:localhost/127.0.0.1:37469]] Connected to server
   12:42:35.971 [pulsar-io-139-1] INFO  
org.apache.pulsar.broker.service.ServerCnx - New connection from 
/127.0.0.1:37510
   12:42:35.971 [pulsar-io-59-1] INFO  org.apache.pulsar.client.impl.ClientCnx 
- [id: 0x11086a07, L:/127.0.0.1:37494 ! R:localhost/127.0.0.1:37469] 
Disconnected
   12:42:35.971 [pulsar-io-139-1] INFO  
org.apache.pulsar.broker.service.ServerCnx - 
[/127.0.0.1:37506][persistent://pulsar/ns/repltopic-ef4b33a0-6916-43d6-b4f6-f1d5a824e1e5]
 Creating producer. producerId=50
   12:42:35.971 [pulsar-io-59-1] ERROR 
org.apache.pulsar.client.impl.ProducerImpl - 
[persistent://pulsar/global/repl/topic1-2424a97a-4436-47df-a3a9-6ea209cdeb66-partition-0]
 [pulsar.repl.r1] Failed to create producer: Disconnected from server at 
localhost/127.0.0.1:37469
   12:42:35.971 [pulsar-io-59-1] WARN  
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/global/repl/topic1-2424a97a-4436-47df-a3a9-6ea209cdeb66-partition-0]
 [pulsar.repl.r1] Could not get connection to broker: Disconnected from server 
at localhost/127.0.0.1:37469 -- Will try again in 0.1 s
   12:42:35.971 [pulsar-io-59-1] ERROR 
org.apache.pulsar.client.impl.ProducerImpl - 
[persistent://pulsar/ns/topic-0-62cba7af-d7b3-4449-a00b-73753282d7f4] 
[pulsar.repl.r1] Failed to create producer: Disconnected from server at 
localhost/127.0.0.1:37469
   12:42:35.971 [pulsar-io-59-1] WARN  
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/ns/topic-0-62cba7af-d7b3-4449-a00b-73753282d7f4] 
[pulsar.repl.r1] Could not get connection to broker: Disconnected from server 
at localhost/127.0.0.1:37469 -- Will try again in 0.361 s
   12:42:35.971 [pulsar-io-59-1] INFO  
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/ns/topic-6-8b6fd7dc-bc7e-4051-b3af-2f576c968a67] 
[pulsar.repl.r1] Closed connection [id: 0x11086a07, L:/127.0.0.1:37494 ! 
R:localhost/127.0.0.1:37469] -- Will try again in 0.1 s
   12:42:35.971 [pulsar-io-59-1] INFO  
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/ns/topic-1-97e6dfbc-282c-4d8e-8683-fa2db1b2b3b2] 
[pulsar.repl.r1] Closed connection [id: 0x11086a07, L:/127.0.0.1:37494 ! 
R:localhost/127.0.0.1:37469] -- Will try again in 0.1 s
   12:42:35.971 [pulsar-io-139-1] INFO  
org.apache.pulsar.broker.service.ServerCnx - 
[/127.0.0.1:37498][persistent://pulsar/ns1/%s-producer_request_hold-3870af4c-7e55-481d-8071-01a9f9e5d56b]
 Creating producer. producerId=1
   12:42:35.972 [pulsar-io-139-1] INFO  
org.apache.pulsar.broker.service.ServerCnx - 
[/127.0.0.1:37498][persistent://pulsar/ns/repltopicbatch-9fa4a023-1232-48f4-b0ca-d90a446e720e]
 Creating producer. producerId=26
   12:42:35.972 [pulsar-io-139-1] INFO  
org.apache.pulsar.broker.service.ServerCnx - 
[/127.0.0.1:36432][persistent://pulsar/ns/repltopic-632b8c15-4ab8-4267-af83-8f76bfad91ee]
 Creating producer. producerId=51
   12:42:35.972 [pulsar-io-59-1] WARN  io.netty.util.concurrent.DefaultPromise 
- An exception was thrown by 
org.apache.pulsar.client.impl.ClientCnx$$Lambda$724/2041057860.operationComplete()
   java.lang.NullPointerException: null
           at 
org.apache.pulsar.client.impl.ClientCnx.lambda$sendRequestAndHandleTimeout$12(ClientCnx.java:858)
 ~[pulsar-client-original-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
           at 
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577)
 [netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:551)
 [netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:490)
 [netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:615) 
[netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:608) 
[netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:117) 
[netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetFailure(AbstractChannel.java:993)
 [netty-transport-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:865) 
[netty-transport-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.channel.DefaultChannelPipeline$HeadContext.write(DefaultChannelPipeline.java:1367)
 [netty-transport-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:717)
 [netty-transport-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:764)
 [netty-transport-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:790)
 [netty-transport-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:758)
 [netty-transport-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:767)
 [netty-transport-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.channel.AbstractChannelHandlerContext$WriteTask.run(AbstractChannelHandlerContext.java:1071)
 [netty-transport-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
 [netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
 [netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384) 
[netty-transport-native-epoll-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
 [netty-common-4.1.51.Final.jar:4.1.51.Final]
           at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 
[netty-common-4.1.51.Final.jar:4.1.51.Final]
           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]
   12:42:35.973 [pulsar-io-59-1] INFO  org.apache.pulsar.client.impl.ClientCnx 
- [id: 0x65146f25, L:/127.0.0.1:37492 ! R:localhost/127.0.0.1:37469] 
Disconnected
   12:42:35.973 [pulsar-io-59-1] INFO  
org.apache.pulsar.client.impl.ConnectionHandler - 
[non-persistent://pulsar/ns-9a6b8b5f-5078-4796-91cd-7931f597a1c6/non-persistent-partitioned-528aecee-9f1a-4515-88e9-02abeea9f5aa-partition-1]
 [pulsar.repl.r1] Closed connection [id: 0x65146f25, L:/127.0.0.1:37492 ! 
R:localhost/127.0.0.1:37469] -- Will try again in 0.1 s
   </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]


Reply via email to