This is an automated email from the ASF dual-hosted git repository.
gyfora pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
from 35604761 [FLINK-29607] Introduce FlinkResourceContext to simplify
observer/reconciler logic
new a6699308 Decouple scaling execution from parallelism computation
new ed6acd45 [FLINK-30574] Detect ineffective scale up operations to avoid
scaling further
new 98eec733 [hotfix] Improve AutoScalerInfo
new 8e41ed5e [hotfix][e2e] Pin busybox version
The 4 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:
docs/content/docs/custom-resource/pod-template.md | 2 +-
.../generated/auto_scaler_configuration.html | 24 ++
e2e-tests/data/flinkdep-cr.yaml | 2 +-
examples/pod-template.yaml | 2 +-
.../operator/autoscaler/AutoScalerInfo.java | 35 ++-
.../operator/autoscaler/JobAutoScaler.java | 5 +-
.../operator/autoscaler/JobVertexScaler.java | 245 +++++++++++++++++++
.../operator/autoscaler/ScalingExecutor.java | 150 +-----------
.../autoscaler/ScalingMetricCollector.java | 55 ++---
.../operator/autoscaler/ScalingSummary.java | 6 +
.../autoscaler/config/AutoScalerOptions.java | 27 +++
.../operator/autoscaler/metrics/ScalingMetric.java | 5 +-
.../operator/autoscaler/AutoScalerInfoTest.java | 100 ++++++++
.../operator/autoscaler/JobVertexScalerTest.java | 268 +++++++++++++++++++++
.../MetricsCollectionAndEvaluationTest.java | 13 +
.../operator/autoscaler/ScalingExecutorTest.java | 153 +-----------
16 files changed, 758 insertions(+), 334 deletions(-)
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobVertexScaler.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/AutoScalerInfoTest.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/JobVertexScalerTest.java
