diff --git a/src/main/java/org/influxdb/impl/InfluxDBImpl.java b/src/main/java/org/influxdb/impl/InfluxDBImpl.java
index a2f1019b6..173788fbb 100644
--- a/src/main/java/org/influxdb/impl/InfluxDBImpl.java
+++ b/src/main/java/org/influxdb/impl/InfluxDBImpl.java
@@ -842,6 +842,8 @@ public void process(final ResponseBody chunkedBody, final Consumer<QueryResult>
         QueryResult queryResult = new QueryResult();
         queryResult.setError("DONE");
         consumer.accept(queryResult);
+      } finally {
+        chunkedBody.close();
       }
     }
   }