This is an automated email from the ASF dual-hosted git repository. dongjoon pushed a commit to branch SPARK-27997 in repository https://gitbox.apache.org/repos/asf/spark.git
commit 64df418dac0bf13cde151fc1f802ff2804dcbe3f Author: Dongjoon Hyun <dongj...@apache.org> AuthorDate: Thu Aug 10 09:14:16 2023 -0700 Rename --- .../org/apache/spark/deploy/k8s/SparkKubernetesClientFactory.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/SparkKubernetesClientFactory.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/SparkKubernetesClientFactory.scala index 8537965857d..245cc924fbd 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/SparkKubernetesClientFactory.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/SparkKubernetesClientFactory.scala @@ -57,14 +57,14 @@ private[spark] object SparkKubernetesClientFactory extends Logging { .orElse(defaultServiceAccountToken) val oauthTokenValue = sparkConf.getOption(oauthTokenConf) val oauthTokenProviderConf = s"$kubernetesAuthConfPrefix.$OAUTH_TOKEN_PROVIDER_CONF_SUFFIX" - val oauthTokenProviderInstance = sparkConf.getOption(oauthTokenProviderConf) + val oauthTokenProvider = sparkConf.getOption(oauthTokenProviderConf) .map(Utils.classForName(_) .getDeclaredConstructor() .newInstance() .asInstanceOf[OAuthTokenProvider]) require( - Seq(oauthTokenFile, oauthTokenValue, oauthTokenProviderInstance).count(_.isDefined) <= 1, + Seq(oauthTokenFile, oauthTokenValue, oauthTokenProvider).count(_.isDefined) <= 1, s"OAuth token should be specified via only one of $oauthTokenFileConf, $oauthTokenConf " + s"or $oauthTokenProviderConf." ) @@ -101,7 +101,7 @@ private[spark] object SparkKubernetesClientFactory extends Logging { .withRequestTimeout(clientType.requestTimeout(sparkConf)) .withConnectionTimeout(clientType.connectionTimeout(sparkConf)) .withTrustCerts(sparkConf.get(KUBERNETES_TRUST_CERTIFICATES)) - .withOption(oauthTokenProviderInstance) { + .withOption(oauthTokenProvider) { (provider, configBuilder) => configBuilder.withOauthTokenProvider(provider) }.withOption(oauthTokenValue) { (token, configBuilder) => configBuilder.withOauthToken(token) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org