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 b0bc3a3b [FLINK-37769] Include cause in event when restarting
unhealthy job
add 0679d634 [FLINK-37730] Expose JM exception as K8s exceptions
No new revisions were added by this update.
Summary of changes:
.../kubernetes_operator_config_configuration.html | 12 ++
.../generated/system_advanced_section.html | 12 ++
.../config/FlinkOperatorConfiguration.java | 12 +-
.../config/KubernetesOperatorConfigOptions.java | 16 ++
.../controller/FlinkDeploymentContext.java | 12 +-
.../operator/controller/FlinkResourceContext.java | 3 +
.../controller/FlinkSessionJobContext.java | 12 +-
.../operator/observer/JobStatusObserver.java | 166 +++++++++++++++-
.../operator/service/AbstractFlinkService.java | 35 ++++
.../service/FlinkResourceContextFactory.java | 54 ++++-
.../kubernetes/operator/service/FlinkService.java | 6 +
.../kubernetes/operator/utils/EventRecorder.java | 22 +++
.../kubernetes/operator/utils/EventUtils.java | 44 +++++
.../operator/utils/K8sAnnotationsSanitizer.java | 131 +++++++++++++
.../kubernetes/operator/OperatorTestBase.java | 16 +-
.../kubernetes/operator/TestingFlinkService.java | 58 +++++-
.../KubernetesJobAutoScalerContextTest.java | 1 +
.../TestingKubernetesAutoscalerUtils.java | 1 +
.../controller/FlinkResourceContextTest.java | 4 +-
.../operator/observer/JobStatusObserverTest.java | 218 +++++++++++++++++++++
.../operator/service/NativeFlinkServiceTest.java | 6 +-
.../kubernetes/operator/utils/EventUtilsTest.java | 78 ++++++++
.../utils/K8sAnnotationsSanitizerTest.java | 123 ++++++++++++
23 files changed, 1017 insertions(+), 25 deletions(-)
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/K8sAnnotationsSanitizer.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/K8sAnnotationsSanitizerTest.java
