(beam) branch master updated: [OpenTelemetry] Default open telemetry configuration behind experiment (#38784)

[radek]

This is an automated email from the ASF dual-hosted git repository.

stankiewicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 36c8db6c75f [OpenTelemetry] Default open telemetry configuration 
behind experiment (#38784)
36c8db6c75f is described below

commit 36c8db6c75fb2553c82174e57611f688d8bb564f
Author: Radosław Stankiewicz <radosl...@google.com>
AuthorDate: Thu Jun 4 09:52:50 2026 +0200

    [OpenTelemetry] Default open telemetry configuration behind experiment 
(#38784)
---
 .../org/apache/beam/runners/dataflow/DataflowRunner.java | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git 
a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
 
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
index 4864f2cf453..011f60f4fd1 100644
--- 
a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
+++ 
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
@@ -48,6 +48,7 @@ import java.nio.channels.ReadableByteChannel;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
+import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
@@ -1327,6 +1328,21 @@ public class DataflowRunner extends 
PipelineRunner<DataflowPipelineJob> {
     if (!ExperimentalOptions.hasExperiment(options, 
"disable_projection_pushdown")) {
       ProjectionPushdownOptimizer.optimize(pipeline);
     }
+    SdkHarnessOptions sdkHarnessOptions = options.as(SdkHarnessOptions.class);
+    if (ExperimentalOptions.hasExperiment(options, "enable_otel_defaults")) {
+      Map<String, String> openTelemetryProperties = 
sdkHarnessOptions.getOpenTelemetryProperties();
+      if (openTelemetryProperties == null) {
+        openTelemetryProperties = new HashMap<>();
+        openTelemetryProperties.put("google.cloud.project", 
options.getProject());
+        openTelemetryProperties.put(
+            "otel.exporter.otlp.endpoint", "https://telemetry.googleapis.com";);
+        openTelemetryProperties.put("otel.traces.exporter", "otlp");
+        openTelemetryProperties.put("otel.java.global-autoconfigure.enabled", 
"true");
+        openTelemetryProperties.put("otel.traces.sampler.arg", "0.01");
+        openTelemetryProperties.put("otel.service.name", options.getAppName());
+        sdkHarnessOptions.setOpenTelemetryProperties(openTelemetryProperties);
+      }
+    }
 
     LOG.info(
         "Executing pipeline on the Dataflow Service, which will have billing 
implications "