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)

Reply via email to