diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/event/JobEventHttpReportHandler.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/event/JobEventHttpReportHandler.java
index fab3201e5ed..1182c726730 100644
--- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/event/JobEventHttpReportHandler.java
+++ b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/event/JobEventHttpReportHandler.java
@@ -33,6 +33,7 @@
 import com.squareup.okhttp.Request;
 import com.squareup.okhttp.RequestBody;
 import com.squareup.okhttp.Response;
+import com.squareup.okhttp.ResponseBody;
 import lombok.extern.slf4j.Slf4j;
 
 import java.io.IOException;
@@ -130,10 +131,12 @@ synchronized void report() throws IOException {
                         .post(RequestBody.create(httpMediaType, events));
         httpHeaders.forEach(requestBuilder::header);
         Response response = httpClient.newCall(requestBuilder.build()).execute();
-        if (response.isSuccessful()) {
-            committedEventIndex += resultSet.readCount();
-        } else {
-            log.error("Failed to request http server: {}", response);
+        try (ResponseBody closeable = response.body()) {
+            if (response.isSuccessful()) {
+                committedEventIndex += resultSet.readCount();
+            } else {
+                log.error("Failed to request http server: {}", response);
+            }
         }
     }