address initial comments and scalastyle issues

Author: ifilonenko

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

@@ -62,7 +62,6 @@ private[spark] class InitContainerConfigurationStepsOrchestrator(
     submissionSparkConf.get(RESOURCE_STAGING_SERVER_INTERNAL_SSL_ENABLED)
       .orElse(submissionSparkConf.get(RESOURCE_STAGING_SERVER_SSL_ENABLED))
       .getOrElse(false)
-
   OptionRequirements.requireNandDefined(
     maybeResourceStagingServerInternalClientCert,
     maybeResourceStagingServerInternalTrustStore,

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/kubernetes/KubernetesClusterManager.scala

@@ -27,9 +27,9 @@ import org.apache.spark.deploy.kubernetes.submit.MountSmallFilesBootstrapImpl
 import org.apache.spark.internal.Logging
 import org.apache.spark.scheduler.{ExternalClusterManager, SchedulerBackend, TaskScheduler, TaskSchedulerImpl}
 import org.apache.spark.util.Utils
+import org.apache.spark.SparkContext
 
 private[spark] class KubernetesClusterManager extends ExternalClusterManager with Logging {
-  import org.apache.spark.SparkContext
   override def canCreate(masterURL: String): Boolean = masterURL.startsWith("k8s")
 
   override def createTaskScheduler(sc: SparkContext, masterURL: String): TaskScheduler = {

resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/kubernetes/InitContainerResourceStagingServerSecretPluginSuite.scala

@@ -23,7 +23,8 @@ import scala.collection.JavaConverters._
 import org.apache.spark.deploy.kubernetes.constants._
 import org.apache.spark.SparkFunSuite
 
-private[spark] class InitContainerResourceStagingServerSecretPluginSuite extends SparkFunSuite with BeforeAndAfter{
+class InitContainerResourceStagingServerSecretPluginSuite
+  extends SparkFunSuite with BeforeAndAfter{
   private val INIT_CONTAINER_SECRET_NAME = "init-secret"
   private val INIT_CONTAINER_SECRET_MOUNT = "/tmp/secret"
 

resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/kubernetes/submit/ClientSuite.scala

@@ -156,7 +156,6 @@ private[spark] class ClientSuite extends SparkFunSuite with BeforeAndAfter {
     val driverJvmOptsEnvs = driverContainer.getEnv.asScala.filter { env =>
       env.getName.startsWith(ENV_JAVA_OPT_PREFIX)
     }.sortBy(_.getName)
-    logInfo(s"driverJVM Options $driverJvmOptsEnvs")
     assert(driverJvmOptsEnvs.size === 6)
 
     val expectedJvmOptsValues = Seq(

resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/kubernetes/submit/submitsteps/InitContainerBootstrapStepSuite.scala

@@ -31,7 +31,7 @@ import org.apache.spark.deploy.kubernetes.constants._
 import org.apache.spark.deploy.kubernetes.submit.submitsteps.initcontainer.{InitContainerConfigurationStep, InitContainerSpec}
 import org.apache.spark.util.Utils
 
-private[spark] class InitContainerBootstrapStepSuite extends SparkFunSuite {
+class InitContainerBootstrapStepSuite extends SparkFunSuite {
 
   private val OBJECT_MAPPER = new ObjectMapper().registerModule(DefaultScalaModule)
   private val CONFIG_MAP_NAME = "spark-init-config-map"

resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/kubernetes/submit/submitsteps/PythonStepSuite.scala

@@ -22,7 +22,7 @@ import scala.collection.JavaConverters._
 
 import org.apache.spark.{SparkConf, SparkFunSuite}
 
-private[spark] class PythonStepSuite extends SparkFunSuite with BeforeAndAfter {
+class PythonStepSuite extends SparkFunSuite with BeforeAndAfter {
   private val FILE_DOWNLOAD_PATH = "/var/data/spark-files"
   private val PYSPARK_FILES = Seq(
     "hdfs://localhost:9000/app/files/file1.py",

resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/kubernetes/integrationtest/KerberizedHadoopClusterLauncher.scala

@@ -54,4 +54,4 @@ private[spark] class KerberizedHadoopClusterLauncher(
        Thread.sleep(500)
      }
    }
-}
+}

resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/kubernetes/integrationtest/KerberosTestPodLauncher.scala

@@ -118,4 +118,4 @@ private[spark] class KerberosTestPodLauncher(
          kubernetesClient.extensions().deployments()
            .inNamespace(namespace).create(deploymentWithEnv)}
   }
-}
+}

resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/kubernetes/integrationtest/KubernetesTestComponents.scala

@@ -19,13 +19,12 @@ package org.apache.spark.deploy.kubernetes.integrationtest
 import java.util.UUID
 
 import io.fabric8.kubernetes.client.DefaultKubernetesClient
+import org.scalatest.concurrent.Eventually
 import scala.collection.JavaConverters._
 
 import org.apache.spark.SparkConf
 import org.apache.spark.deploy.kubernetes.config._
 
-import org.scalatest.concurrent.Eventually
-
 private[spark] class KubernetesTestComponents(defaultClient: DefaultKubernetesClient) {
 
   val namespace = UUID.randomUUID().toString.replaceAll("-", "")

resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/kubernetes/integrationtest/docker/SparkDockerImageBuilder.scala

@@ -24,13 +24,12 @@ import scala.collection.JavaConverters._
 
 import com.spotify.docker.client.{DefaultDockerClient, DockerCertificates, LoggingBuildHandler}
 import org.apache.http.client.utils.URIBuilder
+import org.scalatest.concurrent.{Eventually, PatienceConfiguration}
+import org.scalatest.time.{Minutes, Seconds, Span}
 
 import org.apache.spark.internal.Logging
-
 import org.apache.spark.util.RedirectThread
 
-import org.scalatest.concurrent.{Eventually, PatienceConfiguration}
-import org.scalatest.time.{Minutes, Seconds, Span}
 
 private[spark] class SparkDockerImageBuilder
   (private val dockerEnv: Map[String, String]) extends Logging{