Deadlock

gistfile1.txt

    
Deadlock- jstack of pulsar (when create topic thread gets blocked):

Thread 22396: (state = BLOCKED)
 - sun.misc.Unsafe.park(boolean, long) @bci=0 (Compiled frame; information may be imprecise)
 - java.util.concurrent.locks.StampedLock.acquireWrite(boolean, long) @bci=619, line=1119 (Compiled frame)
 - java.util.concurrent.locks.StampedLock.writeLock() @bci=43, line=354 (Compiled frame)
 - com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.remove(java.lang.Object, java.lang.Object, int) @bci=1, line=302 (Compiled frame)
 - com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.access$200(com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashMap$Section, java.lang.Object, java.lang.Object, int) @bci=4, line=178 (Compiled frame)
 - com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashMap.remove(java.lang.Object, java.lang.Object) @bci=24, line=140 (Interpreted frame)
 - com.yahoo.pulsar.broker.service.BrokerService.lambda$createPersistentTopic$7(java.lang.String, java.util.concurrent.CompletableFuture, java.lang.Throwable) @bci=36, line=517 (Interpreted frame)
 - com.yahoo.pulsar.broker.service.BrokerService$$Lambda$133.apply(java.lang.Object) @bci=16 (Interpreted frame)
 - java.util.concurrent.CompletableFuture.uniExceptionally(java.util.concurrent.CompletableFuture, java.util.function.Function, java.util.concurrent.CompletableFuture$UniExceptionally) @bci=66, line=870 (Compiled frame)
 - java.util.concurrent.CompletableFuture.uniExceptionallyStage(java.util.function.Function) @bci=24, line=884 (Compiled frame)
 - java.util.concurrent.CompletableFuture.exceptionally(java.util.function.Function) @bci=2, line=2196 (Compiled frame)
 - com.yahoo.pulsar.broker.service.BrokerService.createPersistentTopic(java.lang.String, java.util.concurrent.CompletableFuture) @bci=99, line=515 (Compiled frame)
 - com.yahoo.pulsar.broker.service.BrokerService.createPersistentTopic(java.lang.String) @bci=34, line=450 (Compiled frame)
 - com.yahoo.pulsar.broker.service.BrokerService$$Lambda$125.apply(java.lang.Object) @bci=8 (Compiled frame)
 - com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.put(java.lang.Object, java.lang.Object, int, boolean, java.util.function.Function) @bci=204, line=272 (Compiled frame)
 - com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashMap.computeIfAbsent(java.lang.Object, java.util.function.Function) @bci=26, line=127 (Compiled frame)
 - com.yahoo.pulsar.broker.service.BrokerService.getTopic(java.lang.String) @bci=29, line=382 (Compiled frame)
 - com.yahoo.pulsar.broker.service.ServerCnx.lambda$handleProducer$10(long, long, java.lang.String, java.lang.String, java.lang.Boolean) @bci=232, line=492 (Compiled frame)
 - com.yahoo.pulsar.broker.service.ServerCnx$$Lambda$165.apply(java.lang.Object) @bci=24 (Compiled frame)
 - java.util.concurrent.CompletableFuture.uniApply(java.util.concurrent.CompletableFuture, java.util.function.Function, java.util.concurrent.CompletableFuture$UniApply) @bci=85, line=602 (Compiled frame)
 - java.util.concurrent.CompletableFuture.uniApplyStage(java.util.concurrent.Executor, java.util.function.Function) @bci=28, line=614 (Compiled frame)
 - java.util.concurrent.CompletableFuture.thenApply(java.util.function.Function) @bci=3, line=1983 (Compiled frame)
 - com.yahoo.pulsar.broker.service.ServerCnx.handleProducer(com.yahoo.pulsar.common.api.proto.PulsarApi$CommandProducer) @bci=118, line=460 (Compiled frame)
 - com.yahoo.pulsar.common.api.PulsarDecoder.channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object) @bci=602, line=162 (Compiled frame)
 - io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(java.lang.Object) @bci=16, line=366 (Compiled frame)
 - io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(io.netty.channel.AbstractChannelHandlerContext, java.lang.Object) @bci=23, line=352 (Compiled frame)
 - io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(java.lang.Object) @bci=5, line=345 (Compiled frame)
 - io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(io.netty.channel.ChannelHandlerContext, io.netty.handler.codec.CodecOutputList, int) @bci=13, line=293 (Compiled frame)
 - io.netty.handler.codec.ByteToMessageDecoder.channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object) @bci=175, line=267 (Compiled frame)
 - io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(java.lang.Object) @bci=16, line=366 (Compiled frame)
 - io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(io.netty.channel.AbstractChannelHandlerContext, java.lang.Object) @bci=23, line=352 (Compiled frame)
 - io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(java.lang.Object) @bci=5, line=345 (Compiled frame)
 - io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object) @bci=2, line=1294 (Compiled frame)
 - io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(java.lang.Object) @bci=16, line=366 (Compiled frame)
 - io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(io.netty.channel.AbstractChannelHandlerContext, java.lang.Object) @bci=23, line=352 (Compiled frame)
 - io.netty.channel.DefaultChannelPipeline.fireChannelRead(java.lang.Object) @bci=5, line=911 (Compiled frame)
 - io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady() @bci=263, line=883 (Compiled frame)
 - io.netty.channel.epoll.EpollEventLoop.processReady(io.netty.channel.epoll.EpollEventArray, int) @bci=117, line=389 (Compiled frame)
 - io.netty.channel.epoll.EpollEventLoop.run() @bci=134, line=305 (Compiled frame)
 - io.netty.util.concurrent.SingleThreadEventExecutor$2.run() @bci=13, line=140 (Interpreted frame)
 - io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run() @bci=4, line=144 (Interpreted frame)
 - java.lang.Thread.run() @bci=11, line=745 (Interpreted frame)