[flink-kubernetes-operator] branch main updated: [chore] Change the session cluster not found log level to error

[gy...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gyfora 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 407cd7f  [chore] Change the session cluster not found log level to error
407cd7f is described below

commit 407cd7f89c5d4e029a08073a440e1f93beca1b56
Author: Hao Xin <ha...@gmail.com>
AuthorDate: Tue Jun 7 01:36:33 2022 +0800

    [chore] Change the session cluster not found log level to error
---
 .../kubernetes/operator/reconciler/sessionjob/SessionJobHelper.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobHelper.java b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobHelper.java
index 4af66ac..a1f36c2 100644
--- a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobHelper.java
+++ b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobHelper.java
@@ -54,7 +54,7 @@ public class SessionJobHelper {
                 return true;
             }
         } else {
-            logger.info("Session cluster deployment is not found");
+            logger.warn("Session cluster deployment is not found");
             return false;
         }
     }