Skip to content

Commit b15a6fd

Browse files
author
Robert Kruszewski
committed
fix ExecutorPodFactorySuite
1 parent cf547b3 commit b15a6fd

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ class ExecutorPodFactorySuite extends SparkFunSuite with BeforeAndAfter with Bef
8787
}
8888

8989
test("executor core request specification") {
90-
var factory = new ExecutorPodFactory(baseConf, None)
90+
var factory = new ExecutorPodFactory(baseConf, None, None)
9191
var executor = factory.createExecutorPod(
9292
"1", "dummy", "dummy", Seq[(String, String)](), driverPod, Map[String, Int]())
9393
assert(executor.getSpec.getContainers.size() === 1)
@@ -97,15 +97,15 @@ class ExecutorPodFactorySuite extends SparkFunSuite with BeforeAndAfter with Bef
9797
val conf = baseConf.clone()
9898

9999
conf.set(KUBERNETES_EXECUTOR_REQUEST_CORES, "0.1")
100-
factory = new ExecutorPodFactory(conf, None)
100+
factory = new ExecutorPodFactory(conf, None, None)
101101
executor = factory.createExecutorPod(
102102
"1", "dummy", "dummy", Seq[(String, String)](), driverPod, Map[String, Int]())
103103
assert(executor.getSpec.getContainers.size() === 1)
104104
assert(executor.getSpec.getContainers.get(0).getResources.getRequests.get("cpu").getAmount
105105
=== "0.1")
106106

107107
conf.set(KUBERNETES_EXECUTOR_REQUEST_CORES, "100m")
108-
factory = new ExecutorPodFactory(conf, None)
108+
factory = new ExecutorPodFactory(conf, None, None)
109109
conf.set(KUBERNETES_EXECUTOR_REQUEST_CORES, "100m")
110110
executor = factory.createExecutorPod(
111111
"1", "dummy", "dummy", Seq[(String, String)](), driverPod, Map[String, Int]())

0 commit comments

Comments
 (0)