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.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());