mxm commented on PR #711: URL: https://github.com/apache/flink-kubernetes-operator/pull/711#issuecomment-1824128401
Thanks! > On Nov 22, 2023, at 18:21, Alexander Fedulov ***@***.***> wrote: > > > @afedulov commented on this pull request. > > In flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java <https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1402445510>: > > > + .allMatch( > + entry -> { > + var vertexID = entry.getKey(); > + var targetParallelism = entry.getValue(); > + var actualParallelism = actualParallelisms.getOrDefault(vertexID, -1); > + return actualParallelism.equals(targetParallelism); > + }); > + } > + > + /** > + * Retrieves the maximum restart time in seconds based on the provided configuration and scaling > + * records. Defaults to the RESTART_TIME from configuration if the PREFER_TRACKED_RESTART_TIME > + * option is set to false, or if there are no tracking records available. Otherwise, the maximum > + * observed restart time is capped by the MAX_RESTART_TIME. > + */ > + public double getMaxRestartTimeSecondsOrDefault(Configuration conf) { > 93ae804 <https://github.com/apache/flink-kubernetes-operator/commit/93ae804e1466fc75009ca10714a65ad984efbd14> > — > Reply to this email directly, view it on GitHub <https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1402445510>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/AAGMMZONPRUJBC6E3MV5X4TYFYYCTAVCNFSM6AAAAAA7KTCGMGVHI2DSMVQWIX3LMV43YUDVNRWFEZLROVSXG5CSMV3GSZLXHMYTONBUHE4DEMRYGM>. > You are receiving this because you were mentioned. > -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
