From 2a4cbb66656ce2e9b75d3e04046e500e896c0149 Mon Sep 17 00:00:00 2001 From: Stijn De Haes Date: Mon, 4 May 2020 08:29:08 +0200 Subject: [PATCH] Fetch latest state before continuing --- .../k8s/submit/KubernetesClientApplication.scala | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/KubernetesClientApplication.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/KubernetesClientApplication.scala index 25b6b2c568217..f4acb15af4dd0 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/KubernetesClientApplication.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/KubernetesClientApplication.scala @@ -22,11 +22,12 @@ import java.util.{Collections, UUID} import java.util.Properties import io.fabric8.kubernetes.api.model._ +import io.fabric8.kubernetes.client.Watcher.Action import io.fabric8.kubernetes.client.{KubernetesClient, KubernetesClientException, Watch} + import scala.collection.mutable import scala.util.control.NonFatal import util.control.Breaks._ - import org.apache.spark.SparkConf import org.apache.spark.deploy.SparkApplication import org.apache.spark.deploy.k8s._ @@ -145,10 +146,9 @@ private[spark] class Client( breakable { while (true) { try { - watch = kubernetesClient - .pods() - .withName(driverPodName) - .watch(watcher) + val podWithName = kubernetesClient.pods().withName(driverPodName) + watch = podWithName.watch(watcher) + watcher.eventReceived(Action.MODIFIED, podWithName.get()) watcher.watchOrStop(sId) break } catch {