Skip to content

Commit 45ba37d

Browse files
author
nishita-pattanayak
committed
[FLINK-32033][Kubernetes-Operator] Fix Lifecycle status in case of MISSING/ERROR JM status with unrecoverable error
1 parent 150bee1 commit 45ba37d

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/CommonStatus.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,14 @@ public ResourceLifecycleState getLifecycleState() {
100100
if ((jmDeployStatus == JobManagerDeploymentStatus.MISSING
101101
|| jmDeployStatus == JobManagerDeploymentStatus.ERROR)
102102
&& StringUtils.isNotEmpty(error)
103-
&& error.contains("configmaps have been deleted")) {
103+
&& (error.toLowerCase()
104+
.contains(
105+
"it is possible that the job has finished or terminally failed, or the configmaps have been deleted")
106+
|| error.toLowerCase().contains("manual restore required")
107+
|| error.toLowerCase().contains("ha metadata not available")
108+
|| error.toLowerCase()
109+
.contains(
110+
"ha data is not available to make stateful upgrades"))) {
104111
return ResourceLifecycleState.FAILED;
105112
}
106113
}

0 commit comments

Comments
 (0)