diff --git a/http-client/src/main/java/io/airlift/http/client/jetty/JettyHttpClient.java b/http-client/src/main/java/io/airlift/http/client/jetty/JettyHttpClient.java
index <HASH>..<HASH> 100755
--- a/http-client/src/main/java/io/airlift/http/client/jetty/JettyHttpClient.java
+++ b/http-client/src/main/java/io/airlift/http/client/jetty/JettyHttpClient.java
@@ -531,6 +531,14 @@ public class JettyHttpClient
             value = responseHandler.handle(request, jettyResponse);
         }
         finally {
+            if (jettyResponse != null) {
+                try {
+                    jettyResponse.getInputStream().close();
+                }
+                catch (IOException ignored) {
+                    // ignore errors closing the stream
+                }
+            }
             if (recordRequestComplete) {
                 recordRequestComplete(stats, request, requestStart, jettyResponse, responseStart);
             }
Close http client input stream after response handling