Re: [PR] Add CPU and memory size autoscaler quota [flink-kubernetes-operator]

2024-03-04 Thread via GitHub
mxm commented on code in PR #789: URL: https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1511292849 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/EvaluatedMetrics.java: ## @@ -30,6 +31,7 @@ @NoArgsConstructor @AllArgsConstructor

Re: [PR] Add CPU and memory size autoscaler quota [flink-kubernetes-operator]

2024-03-04 Thread via GitHub
mxm commented on code in PR #789: URL: https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1511294060 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/topology/JobTopology.java: ## @@ -97,10 +109,6 @@ public boolean isSource(JobVertexID jobVert

[PR] Add CPU and memory size autoscaler quota [flink-kubernetes-operator]

2024-03-04 Thread via GitHub
gaborgsomogyi opened a new pull request, #789: URL: https://github.com/apache/flink-kubernetes-operator/pull/789 ## What is the purpose of the change Flink can report slot sharing group information in the vertex information. This can be used to fine tune the autoscaler algorithm to de