Adding legacyHostIP to the list of IPs we look at (apache-spark-on-k8…

…s#114)
ifilonenko · Feb 16, 2017 · 1559dbb · 1559dbb
1 parent 112e579
commit 1559dbb
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...e-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala b/...e-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala
@@ -747,9 +747,11 @@ private[spark] class Client(
         node.getSpec.getUnschedulable)
       .flatMap(_.getStatus.getAddresses.asScala)
       // The list contains hostnames, internal and external IP addresses.
-      // we want only external IP addresses in our list
       // (https://kubernetes.io/docs/admin/node/#addresses)
-      .filter(_.getType == "ExternalIP")
+      // we want only external IP addresses and legacyHostIP addresses in our list
+      // legacyHostIPs are deprecated and will be removed in the future.
+      // (https://github.com/kubernetes/kubernetes/issues/9267)
+      .filter(address => address.getType == "ExternalIP" || address.getType == "LegacyHostIP")
       .map(address => {
         s"$urlScheme://${address.getAddress}:$servicePort"
       }).toSet