mateczagany commented on code in PR #558:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/558#discussion_r1156784709
##########
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##########
@@ -645,10 +641,19 @@ public Map<String, String> getClusterInfo(Configuration
conf) throws Exception {
dashboardConfiguration.getFlinkRevision());
}
- // JobManager resource usage can be deduced from the CR
- var jmParameters =
- new KubernetesJobManagerParameters(
- conf, new
KubernetesClusterClientFactory().getClusterSpecification(conf));
+ clusterInfo.putAll(
+ calculateClusterResourceMetrics(
+ conf,
getTaskManagersInfo(conf).getTaskManagerInfos().size()));
+
+ return clusterInfo;
+ }
+
+ private HashMap<String, String> calculateClusterResourceMetrics(
Review Comment:
I have added the new tests in FlinkUtils and rebased to main
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
