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 0f829d9b [hotfix] Simplify diffbuilder array checks and add test
add 9fe68251 [FLINK-32589] Carry over parallelism overrides to prevent
users from clearing them on updates
add 44036fe2 [hotfix] Improve scaling trigger/observe logic to ignore
non-active vertices
add 0c341ebe [FLINK-32615] Cache AutoscalerInfo to avoid always getting
through kubernetes client
No new revisions were added by this update.
Summary of changes:
.../operator/api/docs/CrdReferenceDoclet.java | 8 +
.../operator/api/status/CommonStatus.java | 8 +
.../operator/autoscaler/AutoScalerInfo.java | 85 ++++----
.../operator/autoscaler/AutoscalerInfoManager.java | 128 +++++++++++
.../operator/autoscaler/JobAutoScalerImpl.java | 33 ++-
.../autoscaler/JobAutoscalerFactoryImpl.java | 2 +-
.../operator/autoscaler/ScalingExecutor.java | 36 +---
.../autoscaler/AutoscalerInfoManagerTest.java | 120 +++++++++++
.../operator/autoscaler/AutoscalerTestUtils.java | 15 +-
.../autoscaler/BacklogBasedScalingTest.java | 38 ++--
.../operator/autoscaler/JobAutoScalerImplTest.java | 58 +++++
.../MetricsCollectionAndEvaluationTest.java | 12 +-
.../autoscaler/RecommendedParallelismTest.java | 36 ++--
.../operator/autoscaler/ScalingExecutorTest.java | 30 ++-
.../controller/FlinkDeploymentContext.java | 2 +-
.../operator/controller/FlinkResourceContext.java | 2 +-
.../controller/FlinkSessionJobContext.java | 2 +-
.../metrics/KubernetesOperatorScopeFormat.java | 2 +-
.../KubernetesResourceNamespaceScopeFormat.java | 2 +-
.../metrics/KubernetesResourceScopeFormat.java | 2 +-
.../operator/reconciler/ReconciliationUtils.java | 31 ++-
.../AbstractFlinkResourceReconciler.java | 114 ++++++----
.../reconciler/deployment/JobAutoScaler.java | 10 +-
.../deployment/NoopJobAutoscalerFactory.java | 12 +-
.../kubernetes/operator/service/FlinkService.java | 13 +-
.../operator/service/NativeFlinkService.java | 137 ++++++------
.../operator/service/StandaloneFlinkService.java | 17 +-
.../operator/utils/KubernetesClientUtils.java | 19 --
.../runtime/jobgraph/JobResourceRequirements.java | 2 +-
.../jobgraph/JobVertexResourceRequirements.java | 2 +-
.../kubernetes/operator/TestingFlinkService.java | 6 +-
.../deployment/ApplicationObserverTest.java | 6 +-
.../deployment/ApplicationReconcilerTest.java | 115 +++++++++-
.../operator/service/AbstractFlinkServiceTest.java | 2 +-
.../operator/service/NativeFlinkServiceTest.java | 236 +++++++++++++--------
.../service/StandaloneFlinkServiceTest.java | 32 ++-
.../operator/utils/KubernetesClientUtilsTest.java | 73 -------
.../operator/utils/ReconciliationUtilsTest.java | 36 ++++
38 files changed, 1019 insertions(+), 465 deletions(-)
create mode 100644
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/AutoscalerInfoManager.java
create mode 100644
flink-kubernetes-operator-autoscaler/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/AutoscalerInfoManagerTest.java
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/JobAutoScalerFactory.java
=>
flink-kubernetes-operator-autoscaler/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/AutoscalerTestUtils.java
(66%)
delete mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/KubernetesClientUtilsTest.java
