changed or to and

stijndehaes · stijndehaes · commit dad7ea235f4a · 2020-05-05T18:50:14.000+02:00
diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/LoggingPodStatusWatcher.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/LoggingPodStatusWatcher.scala
@@ -96,7 +96,7 @@ private[k8s] class LoggingPodStatusWatcherImpl(conf: KubernetesDriverConf)
     logInfo(s"Waiting for application ${conf.appName} with submission ID $sId to finish...")
     val interval = conf.get(REPORT_INTERVAL)
     synchronized {
-      while (!podCompleted || !resourceToOldReceived) {
+      while (!podCompleted && !resourceToOldReceived) {
         wait(interval)
         logInfo(s"Application status for $appId (phase: $phase)")
       }

Original file line number	Diff line number	Diff line change
`@@ -96,7 +96,7 @@ private[k8s] class LoggingPodStatusWatcherImpl(conf: KubernetesDriverConf)`
`96`	`96`	`logInfo(s"Waiting for application ${conf.appName} with submission ID $sId to finish...")`
`97`	`97`	`val interval = conf.get(REPORT_INTERVAL)`
`98`	`98`	`synchronized {`
`99`		`- while (!podCompleted \|\| !resourceToOldReceived) {`
	`99`	`+ while (!podCompleted && !resourceToOldReceived) {`
`100`	`100`	`wait(interval)`
`101`	`101`	`logInfo(s"Application status for $appId (phase: $phase)")`
`102`	`102`	`}`