You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by do...@apache.org on 2023/08/10 16:20:20 UTC
[spark] 01/01: Rename
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 <do...@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org