eolivelli commented on issue #9721:
URL: https://github.com/apache/pulsar/issues/9721#issuecomment-787942254
I managed to reproduce with apachepulsar/pulsar-all 2.7.0 docker image (on
JDK8)
```
12:50:32.165 [pulsar-client-io-2-1] INFO
org.apache.pulsar.common.allocator.PulsarByteBufAllocator - Exiting JVM process
for OOM error: failed to allocate 16777216 byte(s) of direct memory (used:
1879048199, max: 1895497728)
io.netty.util.internal.OutOfDirectMemoryError: failed to allocate 16777216
byte(s) of direct memory (used: 1879048199, max: 1895497728)
at
io.netty.util.internal.PlatformDependent.incrementMemoryCounter(PlatformDependent.java:754)
~[io.netty-netty-common-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.util.internal.PlatformDependent.allocateDirectNoCleaner(PlatformDependent.java:709)
~[io.netty-netty-common-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.buffer.PoolArena$DirectArena.allocateDirect(PoolArena.java:755)
~[io.netty-netty-buffer-4.1.51.Final.jar:4.1.51.Final]
at io.netty.buffer.PoolArena$DirectArena.newChunk(PoolArena.java:731)
~[io.netty-netty-buffer-4.1.51.Final.jar:4.1.51.Final]
at io.netty.buffer.PoolArena.allocateNormal(PoolArena.java:247)
~[io.netty-netty-buffer-4.1.51.Final.jar:4.1.51.Final]
at io.netty.buffer.PoolArena.allocate(PoolArena.java:227)
~[io.netty-netty-buffer-4.1.51.Final.jar:4.1.51.Final]
at io.netty.buffer.PoolArena.allocate(PoolArena.java:147)
~[io.netty-netty-buffer-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:356)
~[io.netty-netty-buffer-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:187)
~[io.netty-netty-buffer-4.1.51.Final.jar:4.1.51.Final]
at
org.apache.bookkeeper.common.allocator.impl.ByteBufAllocatorImpl.newDirectBuffer(ByteBufAllocatorImpl.java:164)
[org.apache.bookkeeper-bookkeeper-common-allocator-4.12.0.jar:4.12.0]
at
org.apache.bookkeeper.common.allocator.impl.ByteBufAllocatorImpl.newDirectBuffer(ByteBufAllocatorImpl.java:158)
[org.apache.bookkeeper-bookkeeper-common-allocator-4.12.0.jar:4.12.0]
at
io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:187)
[io.netty-netty-buffer-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:178)
[io.netty-netty-buffer-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.channel.epoll.AbstractEpollChannel.newDirectBuffer0(AbstractEpollChannel.java:328)
[io.netty-netty-transport-native-epoll-4.1.51.Final-linux-x86_64.jar:4.1.51.Final]
at
io.netty.channel.epoll.AbstractEpollChannel.newDirectBuffer(AbstractEpollChannel.java:314)
[io.netty-netty-transport-native-epoll-4.1.51.Final-linux-x86_64.jar:4.1.51.Final]
at
io.netty.channel.epoll.AbstractEpollChannel.newDirectBuffer(AbstractEpollChannel.java:297)
[io.netty-netty-transport-native-epoll-4.1.51.Final-linux-x86_64.jar:4.1.51.Final]
at
io.netty.channel.epoll.AbstractEpollStreamChannel.filterOutboundMessage(AbstractEpollStreamChannel.java:521)
[io.netty-netty-transport-native-epoll-4.1.51.Final-linux-x86_64.jar:4.1.51.Final]
at
io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:873)
[io.netty-netty-transport-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.write(DefaultChannelPipeline.java:1367)
[io.netty-netty-transport-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:717)
[io.netty-netty-transport-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:709)
[io.netty-netty-transport-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:792)
[io.netty-netty-transport-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:702)
[io.netty-netty-transport-4.1.51.Final.jar:4.1.51.Final]
at
org.apache.pulsar.common.protocol.ByteBufPair$Encoder.write(ByteBufPair.java:127)
[org.apache.pulsar-pulsar-common-2.7.0.jar:2.7.0]
at
io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:717)
[io.netty-netty-transport-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:764)
[io.netty-netty-transport-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:790)
[io.netty-netty-transport-4.1.51.Final.jar:4.1.51.Final]
at
io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:758)
[io.netty-netty-transport-4.1.51.Final.jar:4.1.51.Final]
at
org.apache.pulsar.client.impl.ProducerImpl$WriteInEventLoopCallback.run(ProducerImpl.java:764)
[org.apache.pulsar-pulsar-client-original-2.7.0.jar:2.7.0]
```
----------------------------------------------------------------
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]
