[GOBBLIN-2176] Set default java.net.Authenticator in Temporal worke…

…r containers (#4079)
apache · Dec 2, 2024 · 2142d22 · 2142d22
1 parent e5d897e
commit 2142d22
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java b/...temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java
@@ -70,6 +70,7 @@
 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 void start()
     // 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());