This is an automated email from the ASF dual-hosted git repository.
gaborgsomogyi 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 32115490 [FLINK-33105] Log ClusterInfo fetch error as warning
32115490 is described below
commit 321154901c7ec40eefbfb6bacb2808634ae006ab
Author: Gabor Somogyi <[email protected]>
AuthorDate: Tue Sep 19 11:02:51 2023 +0200
[FLINK-33105] Log ClusterInfo fetch error as warning
---
.../operator/observer/deployment/AbstractFlinkDeploymentObserver.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractFlinkDeploymentObserver.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractFlinkDeploymentObserver.java
index 54c2cd4f..fd19713a 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractFlinkDeploymentObserver.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractFlinkDeploymentObserver.java
@@ -86,7 +86,7 @@ public abstract class AbstractFlinkDeploymentObserver
flinkApp.getStatus().getClusterInfo().putAll(clusterInfo);
logger.debug("ClusterInfo: {}",
flinkApp.getStatus().getClusterInfo());
} catch (Exception e) {
- logger.error("Exception while fetching cluster info", e);
+ logger.warn("Exception while fetching cluster info", e);
}
}