This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
from 398a87c9 [FLINK-34329][autoscaler] Fix the bug that scaling report
parser doesn't support Locale
new 746a9967 [FLINK-34178][autoscaler][refactor] Get the jobRunningTs from
JobStatus.RUNNING instead of max timestamp
new 2bd6b1b3 [FLINK-34178][autoscaler] Fix the bug that observed scaling
restart time is always great than `stabilization.interval`
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/flink/autoscaler/JobAutoScalerImpl.java | 22 ++++++++++-----------
.../flink/autoscaler/ScalingMetricCollector.java | 23 +++++++++++++---------
.../apache/flink/autoscaler/ScalingTracking.java | 12 ++++++-----
.../autoscaler/metrics/CollectedMetricHistory.java | 1 +
.../flink/autoscaler/BacklogBasedScalingTest.java | 5 ++++-
.../autoscaler/ScalingMetricCollectorTest.java | 2 +-
.../autoscaler/ScalingMetricEvaluatorTest.java | 20 +++++++++----------
.../flink/autoscaler/TestingMetricsCollector.java | 2 +-
8 files changed, 49 insertions(+), 38 deletions(-)