[spark] 01/01: Rename

[dongjoon]

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