[Issue 253] Fix netty memory leak in TransportResponseHandler (#254)

apache · Jul 12, 2022 · 386dfc9 · 386dfc9
1 parent 691beb7
commit 386dfc9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/common/src/main/java/com/aliyun/emr/rss/common/network/client/TransportResponseHandler.java b/common/src/main/java/com/aliyun/emr/rss/common/network/client/TransportResponseHandler.java
@@ -153,6 +153,7 @@ public void handle(ResponseMessage message) throws Exception {
       if (listener == null) {
         logger.warn("Ignoring response for RPC {} from {} ({} bytes) since it is not outstanding",
           resp.requestId, NettyUtils.getRemoteAddress(channel), resp.body().size());
+        resp.body().release();
       } else {
         outstandingRpcs.remove(resp.requestId);
         try {