Yang LI created FLINK-34563: ------------------------------- Summary: Autoscaling decision improvement Key: FLINK-34563 URL: https://issues.apache.org/jira/browse/FLINK-34563 Project: Flink Issue Type: Improvement Components: Kubernetes Operator Affects Versions: kubernetes-operator-1.7.0 Reporter: Yang LI
Hi, I'd like to propose a minor improvement based on my autoscaling experiments. The concept revolves around identifying the vertex with the highest level of parallelism and matching it to the maximum parallelism supported by our task manager. The primary goal of this enhancement is to prevent any task slots from remaining unused after the Flink autoscaler performs a rescaling operation. I've already tested this modification in a custom build of the operator, excluding the memory tuning feature. However, I believe it could be beneficial, especially in scenarios where the memory tuning feature is not enabled. And I have prepared this small pr also :) -- This message was sent by Atlassian Jira (v8.20.10#820010)