From 8bdf28e04b6e2d5a9771afde40edbd3d98dde5a4 Mon Sep 17 00:00:00 2001
From: weixiuli <weixiuli@jd.com>
Date: Tue, 23 Mar 2021 19:51:29 +0800
Subject: [PATCH] [SPARK-34834][NETWORK] Fix a potential Netty memory leak in
 TransportResponseHandler.

---
 .../apache/spark/network/client/TransportResponseHandler.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/common/network-common/src/main/java/org/apache/spark/network/client/TransportResponseHandler.java b/common/network-common/src/main/java/org/apache/spark/network/client/TransportResponseHandler.java
index 2f143f77fa4ae..3aac2d2441d2a 100644
--- a/common/network-common/src/main/java/org/apache/spark/network/client/TransportResponseHandler.java
+++ b/common/network-common/src/main/java/org/apache/spark/network/client/TransportResponseHandler.java
@@ -188,6 +188,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, getRemoteAddress(channel), resp.body().size());
+        resp.body().release();
       } else {
         outstandingRpcs.remove(resp.requestId);
         try {