Skip to content
This repository was archived by the owner on Jan 9, 2020. It is now read-only.

Commit 3c3331a

Browse files
committed
Fix compile error
1 parent 48533ff commit 3c3331a

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/submit/DriverConfigurationStepsOrchestrator.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ import org.apache.spark.SparkConf
2020
import org.apache.spark.deploy.kubernetes.ConfigurationUtils
2121
import org.apache.spark.deploy.kubernetes.config._
2222
import org.apache.spark.deploy.kubernetes.constants._
23-
import org.apache.spark.deploy.kubernetes.submit.submitsteps.{BaseDriverConfigurationStep, DependencyResolutionStep, DriverConfigurationStep, DriverKubernetesCredentialsStep, InitContainerBootstrapStep, PythonStep}
23+
import org.apache.spark.deploy.kubernetes.submit.submitsteps._
2424
import org.apache.spark.deploy.kubernetes.submit.submitsteps.initcontainer.InitContainerConfigurationStepsOrchestrator
2525
import org.apache.spark.launcher.SparkLauncher
2626
import org.apache.spark.util.Utils
@@ -94,7 +94,7 @@ private[spark] class DriverConfigurationStepsOrchestrator(
9494
submissionSparkConf)
9595
val kubernetesCredentialsStep = new DriverKubernetesCredentialsStep(
9696
submissionSparkConf, kubernetesResourceNamePrefix)
97-
val hadoopTokensStep = new DriverHadoopTokensStep(submissionSparkConf)
97+
val hadoopCredentialsStep = new DriverHadoopCredentialsStep(submissionSparkConf)
9898
val pythonStep = mainAppResource match {
9999
case PythonMainAppResource(mainPyResource) =>
100100
Option(new PythonStep(mainPyResource, additionalPythonFiles, filesDownloadPath))
@@ -132,7 +132,7 @@ private[spark] class DriverConfigurationStepsOrchestrator(
132132
Seq(
133133
initialSubmissionStep,
134134
kubernetesCredentialsStep,
135-
hadoopTokensStep,
135+
hadoopCredentialsStep,
136136
dependencyResolutionStep) ++
137137
initContainerBootstrapStep.toSeq ++
138138
pythonStep.toSeq
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ import org.apache.spark.deploy.kubernetes.config._
2323
import org.apache.spark.deploy.kubernetes.constants._
2424

2525

26-
class DriverHadoopTokensStep(submissionSparkConf: SparkConf) extends DriverConfigurationStep {
26+
class DriverHadoopCredentialsStep(submissionSparkConf: SparkConf) extends DriverConfigurationStep {
2727

2828
private val maybeMountedHadoopSecret = submissionSparkConf.getOption(MOUNTED_HADOOP_SECRET_CONF)
2929

0 commit comments

Comments
 (0)