Rui Fan created FLINK-36940:
-------------------------------
Summary: Why does autoscaler Math.round the
TargetProcessingCapacity
Key: FLINK-36940
URL: https://issues.apache.org/jira/browse/FLINK-36940
Project: Flink
Issue Type: Improvement
Reporter: Rui Fan
AutoScalerUtils#getTargetProcessingCapacity calls
Math.round(lagCatchupTargetRate + restartCatchupRate +
inputTargetAtUtilization);
The return type is double, I don't know why need Math.round here.
I write some end to end tests for autoscaler, and the recommended parallelism
is unexpected. After analysis, I found Math.round is the root cause.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)