You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2020/05/10 13:27:58 UTC

[GitHub] [pulsar] ericwangdka opened a new issue #6934: send message then get oom error

ericwangdka opened a new issue #6934:
URL: https://github.com/apache/pulsar/issues/6934


   when i use pulsar-perf send messages for a while ,then t get oom error ,yet,how can i to do with it?
   
   [pulsar-client-io-2-4] INFO  org.apache.pulsar.common.allocator.PulsarByteBufAllocator - Exiting JVM process for OOM error: failed to allocate 16777216 byte(s) of direct memory (used: 22481469440, max: 22481469440)
   io.netty.util.internal.OutOfDirectMemoryError: failed to allocate 16777216 byte(s) of direct memory (used: 22481469440, max: 22481469440)
           at io.netty.util.internal.PlatformDependent.incrementMemoryCounter(PlatformDependent.java:726) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.util.internal.PlatformDependent.allocateDirectNoCleaner(PlatformDependent.java:681) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.buffer.PoolArena$DirectArena.allocateDirect(PoolArena.java:758) ~[io.netty-netty-buffer-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.buffer.PoolArena$DirectArena.newChunk(PoolArena.java:734) ~[io.netty-netty-buffer-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.buffer.PoolArena.allocateNormal(PoolArena.java:245) ~[io.netty-netty-buffer-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.buffer.PoolArena.allocate(PoolArena.java:227) ~[io.netty-netty-buffer-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.buffer.PoolArena.allocate(PoolArena.java:147) ~[io.netty-netty-buffer-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:342) ~[io.netty-netty-buffer-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:187) ~[io.netty-netty-buffer-4.1.43.Final.jar:4.1.43.Final]
           at org.apache.bookkeeper.common.allocator.impl.ByteBufAllocatorImpl.newDirectBuffer(ByteBufAllocatorImpl.java:164) [org.apache.bookkeeper-bookkeeper-common-allocator-4.10.0.jar:4.10.0]
           at org.apache.bookkeeper.common.allocator.impl.ByteBufAllocatorImpl.newDirectBuffer(ByteBufAllocatorImpl.java:158) [org.apache.bookkeeper-bookkeeper-common-allocator-4.10.0.jar:4.10.0]
           at io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:187) [io.netty-netty-buffer-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:178) [io.netty-netty-buffer-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.handler.ssl.SslHandler$SslEngineType$1.allocateWrapBuffer(SslHandler.java:214) [io.netty-netty-handler-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.handler.ssl.SslHandler.allocateOutNetBuf(SslHandler.java:2155) [io.netty-netty-handler-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.handler.ssl.SslHandler.wrap(SslHandler.java:829) [io.netty-netty-handler-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.handler.ssl.SslHandler.wrapAndFlush(SslHandler.java:800) [io.netty-netty-handler-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.handler.ssl.SslHandler.flush(SslHandler.java:781) [io.netty-netty-handler-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:749) [io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:741) [io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:727) [io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125) [io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:749) [io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:764) [io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:789) [io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:757) [io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
           at org.apache.pulsar.client.impl.ProducerImpl$WriteInEventLoopCallback.run(ProducerImpl.java:666) [org.apache.pulsar-pulsar-client-original-2.5.0.jar:2.5.0]
           at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) [io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:510) [io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:518) [io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1050) [io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]


----------------------------------------------------------------
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:
users@infra.apache.org



[GitHub] [pulsar] ericwangdka closed issue #6934: send message then get oom error

Posted by GitBox <gi...@apache.org>.
ericwangdka closed issue #6934:
URL: https://github.com/apache/pulsar/issues/6934


   


----------------------------------------------------------------
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:
users@infra.apache.org



[GitHub] [pulsar] sijie commented on issue #6934: send message then get oom error

Posted by GitBox <gi...@apache.org>.
sijie commented on issue #6934:
URL: https://github.com/apache/pulsar/issues/6934#issuecomment-626430865


   @ericwangdka When OOM occurs, you can consider increasing the direct memory size. It typically means you are sending faster than your system can support.


----------------------------------------------------------------
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:
users@infra.apache.org



[GitHub] [pulsar] ericwangdka commented on issue #6934: send message then get oom error

Posted by GitBox <gi...@apache.org>.
ericwangdka commented on issue #6934:
URL: https://github.com/apache/pulsar/issues/6934#issuecomment-628346327


   @sijie  thanks a lot,it seems i use the default .


----------------------------------------------------------------
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:
users@infra.apache.org