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/19 08:13:00 UTC

[flink-kubernetes-operator] branch main updated: [FLINK-26655] Improve the observe logic in SessionObserver

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 4148101  [FLINK-26655] Improve the observe logic in SessionObserver
4148101 is described below

commit 41481012b7e57bb8a8c4eee248ea68377a6eb3ce
Author: Biao Geng <gb...@gmail.com>
AuthorDate: Sat Mar 19 13:54:00 2022 +0800

    [FLINK-26655] Improve the observe logic in SessionObserver
    
    This closes #82.
---
 .../apache/flink/kubernetes/operator/observer/SessionObserver.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SessionObserver.java b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SessionObserver.java
index e98e7e2..b70c177 100644
--- a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SessionObserver.java
+++ b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SessionObserver.java
@@ -37,6 +37,9 @@ public class SessionObserver extends BaseObserver {
 
     @Override
     public void observe(FlinkDeployment flinkApp, Context context, Configuration effectiveConfig) {
+        if (!isClusterReady(flinkApp)) {
+            observeJmDeployment(flinkApp, context, effectiveConfig);
+        }
         if (isClusterReady(flinkApp)) {
             // Check if session cluster can serve rest calls following our practice in JobObserver
             try {
@@ -48,8 +51,6 @@ public class SessionObserver extends BaseObserver {
                     observeJmDeployment(flinkApp, context, effectiveConfig);
                 }
             }
-        } else {
-            observeJmDeployment(flinkApp, context, effectiveConfig);
         }
     }
 }