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 ab731f1 commit 0cf0d02Copy full SHA for 0cf0d02
resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala
@@ -570,7 +570,8 @@ private[spark] class Client(
570
.filter(_.getName == SUBMISSION_SERVER_PORT_NAME)
571
.head.getNodePort
572
val nodeUrls = kubernetesClient.nodes.list.getItems.asScala
573
- .filterNot(_.getSpec.getUnschedulable)
+ .filterNot(node => node.getSpec.getUnschedulable != null &&
574
+ node.getSpec.getUnschedulable)
575
.flatMap(_.getStatus.getAddresses.asScala.map(address => {
576
s"$urlScheme://${address.getAddress}:$servicePort"
577
})).toArray
0 commit comments