You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by wa...@apache.org on 2022/03/17 08:12:09 UTC
[flink-kubernetes-operator] branch main updated: [FLINK-26696] Reuse the method of judgment
This is an automated email from the ASF dual-hosted git repository.
wangyang0918 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
The following commit(s) were added to refs/heads/main by this push:
new d7f8b69 [FLINK-26696] Reuse the method of judgment
d7f8b69 is described below
commit d7f8b6905004418da7005d408af921d7a39d1579
Author: Junfan Zhang <ju...@outlook.com>
AuthorDate: Thu Mar 17 15:01:17 2022 +0800
[FLINK-26696] Reuse the method of judgment
---
.../org/apache/flink/kubernetes/operator/observer/JobObserver.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobObserver.java b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobObserver.java
index 69c64e5..3c180ac 100644
--- a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobObserver.java
+++ b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobObserver.java
@@ -47,8 +47,7 @@ public class JobObserver extends BaseObserver {
@Override
public void observe(FlinkDeployment flinkApp, Context context, Configuration effectiveConfig) {
- if (JobManagerDeploymentStatus.READY
- != flinkApp.getStatus().getJobManagerDeploymentStatus()) {
+ if (!isClusterReady(flinkApp)) {
observeJmDeployment(flinkApp, context, effectiveConfig);
}
if (isClusterReady(flinkApp)) {