yuanfenghu created FLINK-36527:
----------------------------------
Summary: Introduce a parameter to support the autoscaler to adopt
a more aggressive strategy when Source or upstream shuffle is keyBy
Key: FLINK-36527
URL: https://issues.apache.org/jira/browse/FLINK-36527
Project: Flink
Issue Type: Improvement
Components: Autoscaler
Reporter: yuanfenghu
In
[https://issues.apache.org/jira/browse/FLINK-36192|https://issues.apache.org/jira/browse/FLINK-36192]
We have completed the optimization of Souce parallelism determination.
Task Source or upstream shuffle is keyBy will be adjusted to be a divisor of
the number of partitions or the maximum degree of parallelism.
This Jira hopes to introduce a parameter to enable a {color:#de350b}more
aggressive{color} strategy :
https://github.com/apache/flink-kubernetes-operator/pull/879#discussion_r1764419949
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
