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)