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

(cherry picked from commit 386dfc9)
apache · Sep 2, 2022 · 03e5049 · 03e5049
1 parent e40b0a5
commit 03e5049
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 {