diff --git a/exporters/otlp/common/src/main/java/io/opentelemetry/exporter/otlp/internal/grpc/OkHttpGrpcExporter.java b/exporters/otlp/common/src/main/java/io/opentelemetry/exporter/otlp/internal/grpc/OkHttpGrpcExporter.java index bc38c980d7d..bdd92904f40 100644 --- a/exporters/otlp/common/src/main/java/io/opentelemetry/exporter/otlp/internal/grpc/OkHttpGrpcExporter.java +++ b/exporters/otlp/common/src/main/java/io/opentelemetry/exporter/otlp/internal/grpc/OkHttpGrpcExporter.java @@ -222,6 +222,7 @@ private static String grpcMessage(Response response) { public CompletableResultCode shutdown() { client.dispatcher().cancelAll(); client.dispatcher().executorService().shutdownNow(); + client.connectionPool().evictAll(); this.seen.unbind(); this.success.unbind(); this.failed.unbind(); diff --git a/exporters/otlp/common/src/main/java/io/opentelemetry/exporter/otlp/internal/okhttp/OkHttpExporter.java b/exporters/otlp/common/src/main/java/io/opentelemetry/exporter/otlp/internal/okhttp/OkHttpExporter.java index f9ea7e2fafa..b888e67d5fc 100644 --- a/exporters/otlp/common/src/main/java/io/opentelemetry/exporter/otlp/internal/okhttp/OkHttpExporter.java +++ b/exporters/otlp/common/src/main/java/io/opentelemetry/exporter/otlp/internal/okhttp/OkHttpExporter.java @@ -127,6 +127,7 @@ public CompletableResultCode shutdown() { final CompletableResultCode result = CompletableResultCode.ofSuccess(); client.dispatcher().cancelAll(); client.dispatcher().executorService().shutdownNow(); + client.connectionPool().evictAll(); exporterMetrics.unbind(); return result; }