[ https://issues.apache.org/jira/browse/FLINK-36527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rui Fan resolved FLINK-36527. ----------------------------- Fix Version/s: kubernetes-operator-1.11.0 Resolution: Fixed Merged to main(1.11.0) via: acc04da2b863df87f407aca9e5018c45741a563c > 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 > Assignee: yuanfenghu > Priority: Minor > Labels: pull-request-available > Fix For: kubernetes-operator-1.11.0 > > > 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)