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

Commit 1bd0384

Browse files
committed
Fix isEmpty and split between lines
1 parent bc856b2 commit 1bd0384

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

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

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -65,8 +65,8 @@ class ExecutorPodFactoryImplSuite extends SparkFunSuite with BeforeAndAfter {
6565
test("basic executor pod has reasonable defaults") {
6666
val factory = new ExecutorPodFactoryImpl(baseConf,
6767
NodeAffinityExecutorPodModifierImpl, None, None, None, None, None)
68-
val executor = factory.createExecutorPod("1", "dummy", "dummy",
69-
Seq[(String, String)](), driverPod, Map[String, Int]())
68+
val executor = factory.createExecutorPod(
69+
"1", "dummy", "dummy", Seq[(String, String)](), driverPod, Map[String, Int]())
7070

7171
// The executor pod name and default labels.
7272
assert(executor.getMetadata.getName == s"$executorPrefix-exec-1")
@@ -76,14 +76,14 @@ class ExecutorPodFactoryImplSuite extends SparkFunSuite with BeforeAndAfter {
7676
// Default memory limit is 1024M + 384M (minimum overhead constant).
7777
assert(executor.getSpec.getContainers.size() == 1)
7878
assert(executor.getSpec.getContainers.get(0).getImage == executorImage)
79-
assert(executor.getSpec.getContainers.get(0).getVolumeMounts.size() == 0)
79+
assert(executor.getSpec.getContainers.get(0).getVolumeMounts.isEmpty)
8080
assert(executor.getSpec.getContainers.get(0).getResources.getLimits.size() == 1)
81-
assert(executor.getSpec.getContainers.get(0).getResources.
82-
getLimits.get("memory").getAmount == "1408Mi")
81+
assert(executor.getSpec.getContainers.get(0).getResources
82+
.getLimits.get("memory").getAmount == "1408Mi")
8383

8484
// The pod has no node selector, volumes.
85-
assert(executor.getSpec.getNodeSelector.size() == 0)
86-
assert(executor.getSpec.getVolumes.size() == 0)
85+
assert(executor.getSpec.getNodeSelector.isEmpty)
86+
assert(executor.getSpec.getVolumes.isEmpty)
8787

8888
checkEnv(executor, Set())
8989
checkOwnerReferences(executor, driverPodUid)
@@ -114,8 +114,8 @@ class ExecutorPodFactoryImplSuite extends SparkFunSuite with BeforeAndAfter {
114114
assert(executor.getSpec.getContainers.size() == 1)
115115
assert(executor.getSpec.getContainers.get(0).getVolumeMounts.size() == 1)
116116
assert(executor.getSpec.getContainers.get(0).getVolumeMounts.get(0).getName == "secret1-volume")
117-
assert(executor.getSpec.getContainers.get(0).getVolumeMounts.get(0).
118-
getMountPath == "/var/secret1")
117+
assert(executor.getSpec.getContainers.get(0).getVolumeMounts.get(0)
118+
.getMountPath == "/var/secret1")
119119

120120
// check volume mounted.
121121
assert(executor.getSpec.getVolumes.size() == 1)
@@ -160,8 +160,8 @@ class ExecutorPodFactoryImplSuite extends SparkFunSuite with BeforeAndAfter {
160160
assert(executor.getSpec.getContainers.size() == 1)
161161
assert(executor.getSpec.getContainers.get(0).getVolumeMounts.size() == 1)
162162
assert(executor.getSpec.getContainers.get(0).getVolumeMounts.get(0).getName == "0-tmp")
163-
assert(executor.getSpec.getContainers.get(0).getVolumeMounts.get(0).
164-
getMountPath == "/tmp")
163+
assert(executor.getSpec.getContainers.get(0).getVolumeMounts.get(0)
164+
.getMountPath == "/tmp")
165165
checkOwnerReferences(executor, driverPodUid)
166166
}
167167

0 commit comments

Comments
 (0)