Address review comments

elastic · Jun 4, 2024 · 6ebb08b · 6ebb08b
1 parent c81da8f
commit 6ebb08b
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/x-pack/filebeat/input/httpjson/policy.go b/x-pack/filebeat/input/httpjson/policy.go
@@ -93,6 +93,7 @@ func (p *Policy) CustomRetryPolicy(ctx context.Context, resp *http.Response, err
 	if resp.StatusCode == 0 || (resp.StatusCode >= 500 && resp.StatusCode != 501) {
 		defer func() {
 			if resp.Body != nil {
+				io.Copy(io.Discard, resp.Body)
 				resp.Body.Close()
 			}
 		}()

diff --git a/x-pack/filebeat/input/httpjson/request.go b/x-pack/filebeat/input/httpjson/request.go
@@ -675,11 +675,6 @@ func (r *requester) processChainPaginationEvents(ctx context.Context, trCtx *tra
 			if err != nil {
 				return -1, fmt.Errorf("failed to collect response: %w", err)
 			}
-			defer func() {
-				if httpResp != nil && httpResp.Body != nil {
-					httpResp.Body.Close()
-				}
-			}()
 
 			// store data according to response type
 			if i == len(r.requestFactories)-1 && len(ids) != 0 {