bugfix(exporter): ensure response is closed

CHANGELOG.md

@@ -47,6 +47,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   ([#4458](https://github.com/open-telemetry/opentelemetry-python/pull/4458))
 - pylint-ci updated python version to 3.13
   ([#4450](https://github.com/open-telemetry/opentelemetry-python/pull/4450))
+- Fix intermittent `Connection aborted` error when using otlp/http exporters
+  ([#4477](https://github.com/open-telemetry/opentelemetry-python/pull/4477))
 
 ## Version 1.30.0/0.51b0 (2025-02-03)
 

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/_log_exporter/__init__.py

@@ -167,8 +167,12 @@ def export(self, batch: Sequence[LogData]) -> LogExportResult:
             resp = self._export(serialized_data)
             # pylint: disable=no-else-return
             if resp.ok:
+                if resp.raw is not None:
+                    resp.close()
                 return LogExportResult.SUCCESS
             elif self._retryable(resp):
+                if resp.raw is not None:
+                    resp.close()
                 _logger.warning(
                     "Transient error %s encountered while exporting logs batch, retrying in %ss.",
                     resp.reason,
@@ -177,6 +181,8 @@ def export(self, batch: Sequence[LogData]) -> LogExportResult:
                 sleep(delay)
                 continue
             else:
+                if resp.raw is not None:
+                    resp.close()
                 _logger.error(
                     "Failed to export logs batch code: %s, reason: %s",
                     resp.status_code,

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/metric_exporter/__init__.py

@@ -207,8 +207,12 @@ def export(
             resp = self._export(serialized_data.SerializeToString())
             # pylint: disable=no-else-return
             if resp.ok:
+                if resp.raw is not None:
+                    resp.close()
                 return MetricExportResult.SUCCESS
             elif self._retryable(resp):
+                if resp.raw is not None:
+                    resp.close()
                 _logger.warning(
                     "Transient error %s encountered while exporting metric batch, retrying in %ss.",
                     resp.reason,
@@ -217,6 +221,8 @@ def export(
                 sleep(delay)
                 continue
             else:
+                if resp.raw is not None:
+                    resp.close()
                 _logger.error(
                     "Failed to export batch code: %s, reason: %s",
                     resp.status_code,

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/trace_exporter/__init__.py

@@ -159,8 +159,12 @@ def _export_serialized_spans(self, serialized_data):
             resp = self._export(serialized_data)
             # pylint: disable=no-else-return
             if resp.ok:
+                if resp.raw is not None:
+                    resp.close()
                 return SpanExportResult.SUCCESS
             elif self._retryable(resp):
+                if resp.raw is not None:
+                    resp.close()
                 _logger.warning(
                     "Transient error %s encountered while exporting span batch, retrying in %ss.",
                     resp.reason,
@@ -169,6 +173,8 @@ def _export_serialized_spans(self, serialized_data):
                 sleep(delay)
                 continue
             else:
+                if resp.raw is not None:
+                    resp.close()
                 _logger.error(
                     "Failed to export batch code: %s, reason: %s",
                     resp.status_code,