(gobblin) branch master updated: [GOBBLIN-2176] Set default `java.net.Authenticator` in Temporal worker containers (#4079)

[kipk]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 2142d22dba [GOBBLIN-2176] Set default `java.net.Authenticator` in 
Temporal worker containers (#4079)
2142d22dba is described below

commit 2142d22dba6897bd8ac96be0b622f6175d9c4cc3
Author: abhishekmjain <abhishekmjai...@gmail.com>
AuthorDate: Tue Dec 3 02:38:01 2024 +0530

    [GOBBLIN-2176] Set default `java.net.Authenticator` in Temporal worker 
containers (#4079)
---
 .../apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java
 
b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java
index 4e55c97772..65d91bab30 100644
--- 
a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java
+++ 
b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java
@@ -70,6 +70,7 @@ import org.apache.gobblin.metrics.RootMetricContext;
 import org.apache.gobblin.metrics.event.EventSubmitter;
 import org.apache.gobblin.metrics.event.GobblinEventBuilder;
 import org.apache.gobblin.metrics.reporter.util.MetricReportUtils;
+import org.apache.gobblin.runtime.AbstractJobLauncher;
 import org.apache.gobblin.runtime.api.TaskEventMetadataGenerator;
 import org.apache.gobblin.temporal.GobblinTemporalConfigurationKeys;
 import 
org.apache.gobblin.temporal.workflows.client.TemporalWorkflowClientFactory;
@@ -224,6 +225,9 @@ public class GobblinTemporalTaskRunner implements 
StandardMetricsBridge {
     // Add a shutdown hook so the task scheduler gets properly shutdown
     addShutdownHook();
 
+    // Update authenticator if set
+    
AbstractJobLauncher.setDefaultAuthenticator(ConfigUtils.configToProperties(this.clusterConfig));
+
     try {
       for (int i = 0; i < this.numTemporalWorkers; i++) {
         workers.add(initiateWorker());