1996fanrui commented on code in PR #875:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/875#discussion_r1738421545
##########
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##########
@@ -156,6 +159,9 @@ public boolean scaleResource(
autoScalerStateStore.storeConfigChanges(context, configOverrides);
+ // Try to clear all delayed scale down requests after scaling.
+ delayedScaleDown.clearAll();
Review Comment:
Hi @gyfora , reply your comment[1] here.
IIUC, the previous logic still exists, if the rescale happens,
`delayedScaleDown.clearAll` will be called (rescale includes scale up). It
means the first trigger time is reset.
Not sure whether your question is answered.
[1]
https://github.com/apache/flink-kubernetes-operator/pull/875#discussion_r1738062495
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
