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

Commit 4f0beb5

Browse files
committed
remove commented code
1 parent 67a99d9 commit 4f0beb5

File tree

1 file changed

+0
-9
lines changed

1 file changed

+0
-9
lines changed

resource-managers/kubernetes/core/src/test/scala/org/apache/spark/scheduler/cluster/k8s/ExecutorPodFactorySuite.scala

-9
Original file line numberDiff line numberDiff line change
@@ -180,15 +180,6 @@ class ExecutorPodFactoryImplSuite extends SparkFunSuite with BeforeAndAfter {
180180
conf.set(KUBERNETES_SHUFFLE_NAMESPACE, "default")
181181
conf.set(KUBERNETES_SHUFFLE_DIR, "/tmp")
182182

183-
/*
184-
val kubernetesExternalShuffleClient = new KubernetesExternalShuffleClientImpl(
185-
SparkTransportConf.fromSparkConf(conf, "shuffle"),
186-
sc.env.securityManager,
187-
sc.env.securityManager.isAuthenticationEnabled())
188-
val shuffleManager = new KubernetesExternalShuffleManagerImpl(
189-
conf, kubernetesClient, kubernetesExternalShuffleClient)
190-
*/
191-
192183
val shuffleManager = mock(classOf[KubernetesExternalShuffleManager])
193184
when(shuffleManager.getExecutorShuffleDirVolumesWithMounts).thenReturn({
194185
val shuffleDirs = Seq("/tmp")

0 commit comments

Comments
 (0)