Skip to content

Commit 6689b74

Browse files
committed
refactor
1 parent c599d24 commit 6689b74

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/HadoopConfExecutorFeatureStep.scala

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,12 @@ import io.fabric8.kubernetes.api.model.{ContainerBuilder, PodBuilder, VolumeBuil
2222
import org.apache.spark.deploy.k8s.{KubernetesConf, SparkPod}
2323
import org.apache.spark.deploy.k8s.Constants._
2424

25-
class HadoopConfExecutorFeatureStep (conf: KubernetesConf)
25+
/**
26+
* Mounts the Hadoop configuration on the executor pod.
27+
*/
28+
private[spark] class HadoopConfExecutorFeatureStep(conf: KubernetesConf)
2629
extends KubernetesFeatureConfigStep {
30+
2731
override def configurePod(pod: SparkPod): SparkPod = {
2832
conf.getOption(HADOOP_CONFIG_MAP_NAME) match {
2933
case Some(hadoopConfigMap) =>

resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/k8s/features/HadoopConfExecutorFeatureStepSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ import org.apache.spark.util.{SparkConfWithEnv, Utils}
3131
class HadoopConfExecutorFeatureStepSuite extends SparkFunSuite {
3232
import SecretVolumeUtils._
3333

34-
test("SPARK-43504: mount hadoop config map in executor side") {
34+
test("SPARK-43504: mounts the hadoop config map on the executor pod") {
3535
val confDir = Utils.createTempDir()
3636
val confFiles = Set("core-site.xml", "hdfs-site.xml")
3737

0 commit comments

Comments
 (0)