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

Commit 67856a5

Browse files
committed
fixed issue with executorPodFactory unit tests
1 parent 87df4a7 commit 67856a5

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -270,8 +270,7 @@ private[spark] class ExecutorPodFactoryImpl(
270270
val (executorHadoopConfPod, executorHadoopConfContainer) =
271271
hadoopBootStrap.map { bootstrap =>
272272
val podWithMainContainer = bootstrap.bootstrapMainContainerAndVolumes(
273-
PodWithMainContainer(executorPodWithNodeAffinity, initBootstrappedExecutorContainer)
274-
)
273+
PodWithMainContainer(executorPodWithNodeAffinity, initBootstrappedExecutorContainer))
275274
(podWithMainContainer.pod, podWithMainContainer.mainContainer)
276275
}.getOrElse(executorPodWithNodeAffinity, initBootstrappedExecutorContainer)
277276

@@ -281,8 +280,7 @@ private[spark] class ExecutorPodFactoryImpl(
281280
PodWithMainContainer(executorHadoopConfPod, executorHadoopConfContainer))
282281
(podWithMainContainer.pod, podWithMainContainer.mainContainer)
283282
}.getOrElse((executorHadoopConfPod, executorHadoopConfContainer))
284-
val resolvedExecutorPod = new PodBuilder(executorKerberosPod)
285-
new PodBuilder(resolvedExecutorPod)
283+
new PodBuilder(executorKerberosPod)
286284
.editSpec()
287285
.addToContainers(executorKerberosContainer)
288286
.endSpec()

0 commit comments

Comments
 (0)