This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
from 562dbbc4 [FLINK-32100] Use the total number of Kafka partitions as the
max source parallelism (#597)
add 9618f519 [FLINK-32102] Aggregate multiple pendingRecords metric per
source if present (#598)
No new revisions were added by this update.
Summary of changes:
.../autoscaler/RestApiMetricsCollector.java | 15 ++++-
.../autoscaler/ScalingMetricCollector.java | 16 ++---
.../operator/autoscaler/metrics/FlinkMetric.java | 9 +++
.../autoscaler/RestApiMetricsCollectorTest.java | 77 ++++++++++++++++++++++
.../kubernetes/operator/TestingFlinkService.java | 13 ++++
5 files changed, 120 insertions(+), 10 deletions(-)
create mode 100644
flink-kubernetes-operator-autoscaler/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/RestApiMetricsCollectorTest.java
