[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #544: [FLINK-31318] Improve stability during backlog processing

["mxm (via GitHub)" <gi...@apache.org>]

mxm commented on code in PR #544:
URL: https://github.com/apache/flink-kubernetes-operator/pull/544#discussion_r1126574669


##########
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingMetricEvaluator.java:
##########
@@ -60,30 +62,66 @@ public class ScalingMetricEvaluator {
 
     private Clock clock = Clock.systemDefaultZone();
 
+    protected static final long BACKLOG_PROC_LAG_SECONDS_THRESHOLD =
+            Duration.ofMinutes(5).toSeconds();

Review Comment:
   We should make that configurable as `MAX_LATENCY` or `MAX_PROCESSING_LATENCY`.



-- 
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-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org