[flink-kubernetes-operator] branch main updated: [FLINK-30146] Log job listing exception as warning

[mbalassi]

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

mbalassi 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 15983525 [FLINK-30146] Log job listing exception as warning
15983525 is described below

commit 15983525cf44dcec578a0ee87c1582cf698a6f16
Author: Gabor Somogyi <gabor_somog...@apple.com>
AuthorDate: Wed Dec 7 12:39:32 2022 +0100

    [FLINK-30146] Log job listing exception as warning
---
 e2e-tests/utils.sh                                                      | 1 -
 .../apache/flink/kubernetes/operator/observer/JobStatusObserver.java    | 2 +-
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git a/e2e-tests/utils.sh b/e2e-tests/utils.sh
index 32cdd593..85113622 100755
--- a/e2e-tests/utils.sh
+++ b/e2e-tests/utils.sh
@@ -140,7 +140,6 @@ function check_operator_log_for_errors {
   operator_pod_name=$(get_operator_pod_name)
   echo "Operator namespace: ${operator_pod_namespace} pod: 
${operator_pod_name}"
   errors=$(kubectl logs -n "${operator_pod_namespace}" "${operator_pod_name}" \
-      | grep -v "Exception while listing jobs" 
`#https://issues.apache.org/jira/browse/FLINK-30146` \
       | grep -v "Failed to submit a listener notification task" 
`#https://issues.apache.org/jira/browse/FLINK-30147` \
       | grep -v "Failed to submit job to session cluster" 
`#https://issues.apache.org/jira/browse/FLINK-30148` \
       | grep -v "Error during event processing" 
`#https://issues.apache.org/jira/browse/FLINK-30149` \
diff --git 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java
 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java
index b70c761a..9e5ac8e3 100644
--- 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java
+++ 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java
@@ -77,7 +77,7 @@ public abstract class JobStatusObserver<
             clusterJobStatuses = new 
ArrayList<>(flinkService.listJobs(ctx.getDeployedConfig()));
         } catch (Exception e) {
             // Error while accessing the rest api, will try again later...
-            LOG.error("Exception while listing jobs", e);
+            LOG.warn("Exception while listing jobs", e);
             ifRunningMoveToReconciling(jobStatus, previousJobStatus);
             if (e instanceof TimeoutException) {
                 onTimeout(resource, resourceContext, ctx);