styling

Author: ifilonenko

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

@@ -107,12 +107,12 @@ private[spark] class DriverConfigurationStepsOrchestrator(
       } else {
         val hadoopStepsOrchestrator = new HadoopStepsOrchestrator(
           namespace,
-          kubernetesResourceNamePrefix,
+          hadoopConfigMapName,
           submissionSparkConf,
           hadoopConfigurations)
         val hadoopConfSteps =
           hadoopStepsOrchestrator.getHadoopSteps()
-        Some(new HadoopConfigBootstrapStep(hadoopConfSteps, kubernetesResourceNamePrefix))
+        Some(new HadoopConfigBootstrapStep(hadoopConfSteps, hadoopConfigMapName))
       }
     val pythonStep = mainAppResource match {
       case PythonMainAppResource(mainPyResource) =>

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

@@ -20,16 +20,17 @@ import java.io.StringWriter
 import java.util.Properties
 
 import io.fabric8.kubernetes.api.model.{ConfigMap, ConfigMapBuilder, HasMetadata}
+
 import org.apache.spark.deploy.kubernetes.constants._
 import org.apache.spark.deploy.kubernetes.submit.submitsteps.hadoopsteps.{HadoopConfigSpec, HadoopConfigurationStep}
 
  /**
   * Configures the driverSpec that bootstraps dependencies into the driver pod.
   */
 private[spark] class HadoopConfigBootstrapStep(
-  hadoopConfigurationSteps: Seq[HadoopConfigurationStep], kubernetesResourceNamePrefix: String)
+  hadoopConfigurationSteps: Seq[HadoopConfigurationStep],
+  hadoopConfigMapName: String )
   extends DriverConfigurationStep {
-  private val hadoopConfigMapName = s"$kubernetesResourceNamePrefix-hadoop-config"
 
   override def configureDriver(driverSpec: KubernetesDriverSpec): KubernetesDriverSpec = {
     import scala.collection.JavaConverters._

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/submit/submitsteps/hadoopsteps/HadoopStepsOrchestrator.scala

@@ -28,10 +28,9 @@ import org.apache.spark.deploy.kubernetes.config._
   */
 private[spark] class HadoopStepsOrchestrator(
   namespace: String,
-  kubernetesResourceNamePrefix: String,
+  hadoopConfigMapName: String,
   submissionSparkConf: SparkConf,
   hadoopConfigurationFiles: Array[File]) {
-  private val hadoopConfigMapName = s"$kubernetesResourceNamePrefix-hadoop-config"
   private val maybeKerberosSupport = submissionSparkConf.get(KUBERNETES_KERBEROS_SUPPORT)
 
   def getHadoopSteps(): Seq[HadoopConfigurationStep] = {