Apply WRITE_BUFFER_WATER_MARK setting to child channels in BookieNett…

…yServer (#4337) Signed-off-by: ZhangJian He <[email protected]>
apache · May 4, 2024 · 9b4599b · 9b4599b
1 parent eee9492
commit 9b4599b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieNettyServer.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieNettyServer.java
@@ -314,7 +314,7 @@ private void listenOn(InetSocketAddress address, BookieSocketAddress bookieAddre
             bootstrap.childOption(ChannelOption.RCVBUF_ALLOCATOR,
                     new AdaptiveRecvByteBufAllocator(conf.getRecvByteBufAllocatorSizeMin(),
                             conf.getRecvByteBufAllocatorSizeInitial(), conf.getRecvByteBufAllocatorSizeMax()));
-            bootstrap.option(ChannelOption.WRITE_BUFFER_WATER_MARK, new WriteBufferWaterMark(
+            bootstrap.childOption(ChannelOption.WRITE_BUFFER_WATER_MARK, new WriteBufferWaterMark(
                     conf.getServerWriteBufferLowWaterMark(), conf.getServerWriteBufferHighWaterMark()));
 
             if (eventLoopGroup instanceof IOUringEventLoopGroup){