(beam) branch master updated: [OpenTelemetry] Turn off gcp otel auth extension by default. (#38940)

[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 5afb93c8c09 [OpenTelemetry] Turn off gcp otel auth extension by 
default. (#38940)
5afb93c8c09 is described below

commit 5afb93c8c09f099edc76041540ec01161f94c978
Author: Radosław Stankiewicz <radosl...@google.com>
AuthorDate: Wed Jun 24 18:56:23 2026 +0200

    [OpenTelemetry] Turn off gcp otel auth extension by default. (#38940)
    
    * turn off gcp otel auth extension by default.
---
 .../beam/runners/dataflow/worker/StreamingDataflowWorker.java       | 6 ++++++
 .../harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java | 6 ++++++
 2 files changed, 12 insertions(+)

diff --git 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java
 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java
index 9f063d39370..180dda153bb 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java
@@ -1061,6 +1061,12 @@ public final class StreamingDataflowWorker {
             }
           });
       LOG.info("Enabled Open Telemetry with properties: {}", 
openTelemetryProperties);
+    } else {
+      // turn off auth extension so it doesn't interfere if user is 
configuring otel e.g. via
+      // JvmInitializer.
+      if (System.getProperty("google.otel.auth.target.signals") == null) {
+        System.setProperty("google.otel.auth.target.signals", "none");
+      }
     }
 
     LOG.debug("Creating StreamingDataflowWorker from options: {}", options);
diff --git 
a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java 
b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java
index 60e83251f14..7bda0e18cad 100644
--- a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java
+++ b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java
@@ -315,6 +315,12 @@ public class FnHarness {
               }
             });
         LOG.info("Enabled Open Telemetry with properties: {}", 
openTelemetryProperties);
+      } else {
+        // turn off auth extension so it doesn't interfere if user is 
configuring otel e.g. via
+        // JvmInitializer.
+        if (System.getProperty("google.otel.auth.target.signals") == null) {
+          System.setProperty("google.otel.auth.target.signals", "none");
+        }
       }
       EnumMap<
               BeamFnApi.InstructionRequest.RequestCase,