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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org