We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6726b11 commit e4e6cddCopy full SHA for e4e6cdd
integration-test/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/KubernetesSuite.scala
@@ -71,7 +71,12 @@ private[spark] class KubernetesSuite extends FunSuite with BeforeAndAfterAll wit
71
72
test("Run SparkPi with a master URL without a scheme.") {
73
val url = kubernetesTestComponents.kubernetesClient.getMasterUrl
74
- sparkAppConf.set("spark.master", s"k8s://${url.getHost}:${url.getPort}")
+ val k8sMasterUrl = if (url.getPort < 0) {
75
+ s"k8s://${url.getHost}"
76
+ } else {
77
+ s"k8s://${url.getHost}:${url.getPort}"
78
+ }
79
+ sparkAppConf.set("spark.master", k8sMasterUrl)
80
runSparkPiAndVerifyCompletion()
81
}
82
0 commit comments