Sample logs consistently with traces

open-telemetry · Oct 22, 2024 · ca34e38 · ca34e38
1 parent 62df132
commit ca34e38
Showing 1 changed file with 21 additions and 15 deletions.
diff --git a/sdk/logs/src/main/java/io/opentelemetry/sdk/logs/SdkLogRecordBuilder.java b/sdk/logs/src/main/java/io/opentelemetry/sdk/logs/SdkLogRecordBuilder.java
@@ -11,6 +11,8 @@
 import io.opentelemetry.api.logs.LogRecordBuilder;
 import io.opentelemetry.api.logs.Severity;
 import io.opentelemetry.api.trace.Span;
+import io.opentelemetry.api.trace.SpanContext;
+import io.opentelemetry.api.trace.TraceFlags;
 import io.opentelemetry.context.Context;
 import io.opentelemetry.sdk.common.InstrumentationScopeInfo;
 import io.opentelemetry.sdk.internal.AttributesMap;
@@ -119,20 +121,24 @@ public void emit() {
         this.observedTimestampEpochNanos == 0
             ? this.loggerSharedState.getClock().now()
             : this.observedTimestampEpochNanos;
-    loggerSharedState
-        .getLogRecordProcessor()
-        .onEmit(
-            context,
-            SdkReadWriteLogRecord.create(
-                loggerSharedState.getLogLimits(),
-                loggerSharedState.getResource(),
-                instrumentationScopeInfo,
-                timestampEpochNanos,
-                observedTimestampEpochNanos,
-                Span.fromContext(context).getSpanContext(),
-                severity,
-                severityText,
-                body,
-                attributes));
+    SpanContext spanContext = Span.fromContext(context).getSpanContext();
+    TraceFlags traceFlags = spanContext.getTraceFlags();
+    if (!traceFlags.isSampled()) {
+      loggerSharedState
+          .getLogRecordProcessor()
+          .onEmit(
+              context,
+              SdkReadWriteLogRecord.create(
+                  loggerSharedState.getLogLimits(),
+                  loggerSharedState.getResource(),
+                  instrumentationScopeInfo,
+                  timestampEpochNanos,
+                  observedTimestampEpochNanos,
+                  spanContext,
+                  severity,
+                  severityText,
+                  body,
+                  attributes));
+    }
   }
 }