File tree Expand file tree Collapse file tree 1 file changed +11
-5
lines changed
integration-test/src/test/scala/org/apache/spark/deploy/k8s/integrationtest Expand file tree Collapse file tree 1 file changed +11
-5
lines changed Original file line number Diff line number Diff line change @@ -21,6 +21,8 @@ import java.nio.file.Paths
21
21
import java .util .UUID
22
22
import java .util .regex .Pattern
23
23
24
+ import scala .collection .JavaConverters ._
25
+
24
26
import com .google .common .io .PatternFilenameFilter
25
27
import io .fabric8 .kubernetes .api .model .Pod
26
28
import org .scalatest .{BeforeAndAfter , BeforeAndAfterAll , FunSuite }
@@ -91,11 +93,15 @@ private[spark] class KubernetesSuite extends FunSuite with BeforeAndAfterAll wit
91
93
assert(driverPod.getMetadata.getAnnotations.get(" annotation2" ) === " annotation2-value" )
92
94
93
95
val driverContainer = driverPod.getSpec.getContainers.get(0 )
94
- assert(driverContainer.getEnv.size() == 2 )
95
- assert(driverContainer.getEnv.get(0 ).getName === " ENV1" )
96
- assert(driverContainer.getEnv.get(0 ).getValue === " VALUE1" )
97
- assert(driverContainer.getEnv.get(1 ).getName === " ENV2" )
98
- assert(driverContainer.getEnv.get(1 ).getValue === " VALUE2" )
96
+ val envVars = driverContainer
97
+ .getEnv
98
+ .asScala
99
+ .map { env =>
100
+ (env.getName, env.getValue)
101
+ }
102
+ .toMap
103
+ assert(envVars(" ENV1" ) === " VALUE1" )
104
+ assert(envVars(" ENV2" ) === " VALUE2" )
99
105
})
100
106
}
101
107
You can’t perform that action at this time.
0 commit comments