From 9ae63b9bb4ca3d9bd0caceb975b6709bd0203fbc Mon Sep 17 00:00:00 2001 From: Radoslav Kirilov Date: Fri, 27 Sep 2024 00:29:30 +0300 Subject: [PATCH] fix: LambdaUtils forceFlush flushes Logs also --- .../instrumentation/awslambdacore/v1_0/LambdaUtils.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/instrumentation/aws-lambda/aws-lambda-core-1.0/library/src/main/java/io/opentelemetry/instrumentation/awslambdacore/v1_0/LambdaUtils.java b/instrumentation/aws-lambda/aws-lambda-core-1.0/library/src/main/java/io/opentelemetry/instrumentation/awslambdacore/v1_0/LambdaUtils.java index 5a3bfcb50d4c..644755f62364 100644 --- a/instrumentation/aws-lambda/aws-lambda-core-1.0/library/src/main/java/io/opentelemetry/instrumentation/awslambdacore/v1_0/LambdaUtils.java +++ b/instrumentation/aws-lambda/aws-lambda-core-1.0/library/src/main/java/io/opentelemetry/instrumentation/awslambdacore/v1_0/LambdaUtils.java @@ -15,7 +15,9 @@ final class LambdaUtils { static void forceFlush(OpenTelemetrySdk openTelemetrySdk, long flushTimeout, TimeUnit unit) { CompletableResultCode traceFlush = openTelemetrySdk.getSdkTracerProvider().forceFlush(); CompletableResultCode metricsFlush = openTelemetrySdk.getSdkMeterProvider().forceFlush(); - CompletableResultCode.ofAll(Arrays.asList(traceFlush, metricsFlush)).join(flushTimeout, unit); + CompletableResultCode logsFlush = openTelemetrySdk.getSdkLoggerProvider().forceFlush(); + CompletableResultCode.ofAll(Arrays.asList(traceFlush, metricsFlush, logsFlush)) + .join(flushTimeout, unit); } private LambdaUtils() {}