fix watch job bug (#2997)

apache · Aug 30, 2023 · 5fd0760 · 5fd0760
1 parent 81c73c3
commit 5fd0760
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/...main/scala/org/apache/streampark/flink/kubernetes/helper/KubernetesDeploymentHelper.scala b/...main/scala/org/apache/streampark/flink/kubernetes/helper/KubernetesDeploymentHelper.scala
@@ -58,7 +58,13 @@ object KubernetesDeploymentHelper extends Logger {
   def getDeploymentStatusChanges(nameSpace: String, deploymentName: String): Boolean = {
     Try {
       val pods = getPods(nameSpace, deploymentName)
-      pods.head.getStatus.getContainerStatuses.head.getLastState.getTerminated != null
+      val podStatus = pods.head.getStatus
+      podStatus.getPhase match {
+        case "Unknown" => return true
+        case "Failed" => return true
+        case "Pending" => return false
+        case _ => podStatus.getContainerStatuses.head.getLastState.getTerminated != null
+      }
     }.getOrElse(true)
   }