diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/KubernetesUtils.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/KubernetesUtils.scala index 2738ee8fe9d20..5b0508b20f4ba 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/KubernetesUtils.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/KubernetesUtils.scala @@ -16,6 +16,8 @@ */ package org.apache.spark.deploy.k8s +import io.fabric8.kubernetes.api.model.{Pod, PodBuilder} + import org.apache.spark.SparkConf import org.apache.spark.util.Utils diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/ExecutorKubernetesCredentialsFeatureStep.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/ExecutorKubernetesCredentialsFeatureStep.scala index 010b7c633027b..9dfe9470f4020 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/ExecutorKubernetesCredentialsFeatureStep.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/ExecutorKubernetesCredentialsFeatureStep.scala @@ -16,11 +16,13 @@ */ package org.apache.spark.deploy.k8s.features +import io.fabric8.kubernetes.api.model.HasMetadata + import org.apache.spark.deploy.k8s.{KubernetesConf, SparkPod} import org.apache.spark.deploy.k8s.Config.KUBERNETES_SERVICE_ACCOUNT_NAME import org.apache.spark.deploy.k8s.KubernetesUtils.buildPodWithServiceAccount -private[spark] class ExecutorKubernetesCredentialsFeatureStep(kubernetesConf: KubernetesConf) +private[spark] class ExecutorKubernetesCredentialsFeatureStep(kubernetesConf: KubernetesConf[_]) extends KubernetesFeatureConfigStep { private lazy val driverServiceAccount = kubernetesConf.get(KUBERNETES_SERVICE_ACCOUNT_NAME) @@ -34,4 +36,12 @@ private[spark] class ExecutorKubernetesCredentialsFeatureStep(kubernetesConf: Ku pod.pod }) } -} + + override def getAdditionalKubernetesResources(): Seq[HasMetadata] = { + Seq.empty + } + + override def getAdditionalPodSystemProperties(): Map[String, String] = { + Map.empty + } +} \ No newline at end of file