diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java index 078eaf9cb9..8a1179ed1f 100644 --- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java +++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java @@ -95,6 +95,7 @@ import io.netty.handler.ssl.SslHandler; import io.netty.handler.timeout.IdleState; import io.netty.handler.timeout.IdleStateEvent; +import io.netty.util.ReferenceCountUtil; import io.opentelemetry.api.trace.Span; import io.opentelemetry.semconv.trace.attributes.SemanticAttributes; @@ -443,7 +444,9 @@ protected void channelRead0(ChannelHandlerContext ctx, HttpRequest httpRequest) } } catch (Exception ex) { - log.error("execute AbstractHTTPServer.HTTPHandler.channelRead0 error", ex); + log.error("AbrstractHTTPServer.HTTPHandler.channelRead error", ex); + } finally { + ReferenceCountUtil.release(httpRequest); } }