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 2019/04/29 07:17:50 UTC
[GitHub] [pulsar] hellozepp commented on issue #4063: [pulsar-common]
MaxMessageSize to user configuration
hellozepp commented on issue #4063: [pulsar-common] MaxMessageSize to user configuration
URL: https://github.com/apache/pulsar/pull/4063#issuecomment-487473968
@ambition119 HTAL
I tried to modify the configuration of bk_server to nettyMaxFrameSizeBytes=52428800(50M). Sending 5M data addEntry can be successful, but the following exception occurred when readEntries:
`
2019-04-29 15:10:37, 498-error - [bookie-io-1-2: bookierequesthandler-70] - Unhandled exception occurred in I/O thread or handler
Java.io.IOException: Connection reset by peer
At sun. Nio. Ch. FileDispatcherImpl. Read0 (Native Method)
At sun. Nio. Ch. SocketDispatcher. Read (39) SocketDispatcher. Java:
At sun. Nio. Ch. IOUtil. ReadIntoNativeBuffer (IOUtil. Java: 223)
At sun. Nio. Ch. IOUtil. Read (IOUtil. Java: 192)
At sun. Nio. Ch. SocketChannelImpl. Read (SocketChannelImpl. Java: 380)
At io.net, ty. Buffer. PooledUnsafeDirectByteBuf. SetBytes (PooledUnsafeDirectByteBuf. Java: 288)
At io.net, ty. Buffer. AbstractByteBuf. WriteBytes (AbstractByteBuf. Java: 1132)
At io.net, ty. Channel. The socket. Nio. NioSocketChannel. DoReadBytes (NioSocketChannel. Java: 347)
At io.net ty. Channel. Nio. AbstractNioByteChannel $NioByteUnsafe. Read (AbstractNioByteChannel. Java: 148)
At io.net, ty. Channel. Nio. NioEventLoop. ProcessSelectedKey (NioEventLoop. Java: 648)
At io.net, ty. Channel. Nio. NioEventLoop. ProcessSelectedKeysOptimized (NioEventLoop. Java: 583)
At io.net, ty. Channel. Nio. NioEventLoop. ProcessSelectedKeys (NioEventLoop. Java: 500)
At io.net, ty. Channel. Nio. NioEventLoop. Run (NioEventLoop. Java: 462)
At io.net ty. Util. Concurrent. SingleThreadEventExecutor $5. The run (SingleThreadEventExecutor. Java: 897)
At io.net, ty. Util. Concurrent. FastThreadLocalRunnable. Run (30) FastThreadLocalRunnable. Java:
The at Java. Lang. Thread. The run (Thread. Java: 748)`
----------------------------------------------------------------
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
With regards,
Apache Git Services