This is an automated email from the ASF dual-hosted git repository. gyfora pushed a change to branch release-1.0 in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
from ac50e32 [FLINK-28025] Document the change of serviceAccount in upgrading doc of k8s opeator new cc9a45b [release] Update version to 1.1-SNAPSHOT new 7afa8bc [hotfix] Change version of documentation in update_branch_version.sh new cfddab5 [build] Add doc build for new release branch new 4246e6a [FLINK-27520] Use admission-controller-framework in Webhook new 1785f6f [FLINK-27714] Migrate to java-operator-sdk v3 new 29e615b [FLINK-26179] Support for periodic savepoints new b0ee3db Upgrading cert-manager to version 1.8.0 new aa1c9b4 [chore] Change the session cluster not found log level to error new 1ea5c76 [FLINK-27257] Retry failed savepoints within grace period new 01a3b28 [FLINK-27646] Flink Operator roadmap.md new ab58abf [FLINK-27497] Track terminal job states in the observer new f3147c7 [FLINK-27913] Remove savepointHistoryMaxCount and savepointHistoryMaxAge from FlinkOperatorConfiguration new 156105b [FLINK-27685] Add scale subresource and basic HPA support new 708486f [FLINK-27960] Make the apt-get updating optional new 8aec858 [FLINK-27613] Add label for the session job to help list the session cluster new 6d67821 [FLINK-27892] More than 1 secondary resource related to primary new 4e0dd07 [hotfix] e2e test new 1d1040b [FLINK-28087] Add validation for the meta.name of FlinkDeployment CR new 898bcec [FLINK-27812] Support Dynamic Change of Watched Namespaces new c50c0ca [FLINK-27688] Add pluggable FlinkResourceListener interface new 44d48e0 [FLINK-28059] Parallelize e2e tests new 16abe17 [FLINK-27820] Handle deployment errors on observe new f421fcd [FLINK-27788] Adding annotation to k8 operator Pod new 9e9b1b8 [FLINK-28166] Configurable Automatic Retries on Error new aaf2f71 [FLINK-27912] Improve operator config names new c243b38 [FLINK-28233] Clear error status correctly for stable deployments new 57a5859 [FLINK-27788] Custom labels for the operator pod new c3299ea [FLINK-28008] Can not get secondary resource from context after operator restart new d96e852 [hotfix] Add Ingress lifecycle test new fbc83c5 [FLINK-28180] Unify Application and SessionJob reconciler logic new 36ed53d [FLINK-27280] Unify stability checking for application/session jobs new 3024947 [apple] Rio build for main-acs branch new 20ab322 [apple] Use ACS flink version new 9c7dd3e [apple] VPAF env new ab63e3c [apple] Added internal network policy for separate sdr app new 52a4cb8 [apple] Helm chart publish via Rio new 124a88f [apple] add fluent-bit custom dockerfile new 534cf82 [apple] Locus Kube setup new 62769ed [apple] Kustomize based templating for user envs new e3b27e3 [apple] Structured logging and podtemplate improvements new 4343e59 [apple] Kube examples with kustomize new 6c7abc9 [apple] added render script to apple/helm/kustomize/base/ new 25d6e1e [apple] Pom and kustomize updates new c008282 [apple] Watch multiple namespaces on Kube new f5cf2f1 [apple] add base-kube with splunk new d1c3a1a [apple] Hubble metrics for the operator new e6160c6 [apple] Rework AppleNetworkPolicies to use acs.flink label new 5042e2d [apple][metrics] Improve Hubble DC on Kube new dd8dbff [apple] Rolling appender for structured logging new 94176da [apple] added apple/helm/kustomize/fear-prod/ new b4acb53 [apple][rio] Add maven publish pipeline new c6008c0 [rio] Update for release-1.0-acs branch new 799441c [apple] Introduce Datalake and VPAF prod new b789e7a [apple] Added KafkaFlinkResourceListener new ea4d6d7 [apple][docker] Disable OS update on local image build new cb0ba7b [apple] Set cluster id and cluster type as env variables new 35cea28 [apple] upgraded FEAR clusters new 741bda8 [apple] Mezu secrets for EKS new e2eba2c [apple] rio version bump new 0d4492e [apple] move the image version to env specific values.yaml new 5c0bc23 [apple] Datalake Prod2 new 8558d98 [apple] add dc to KafkaKey new 1cc5727 [apple] Deployment updates for release-1.1 new a8b0284 [apple] enabling kafka listener in datalake-qa new 1ff72b3 README and doc updates for 1.0.1 The 65 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: .github/workflows/ci.yml | 61 ++-- .github/workflows/docker-bake.hcl | 3 + .github/workflows/docs.yaml | 12 +- Dockerfile | 49 ++- README.md | 2 +- .../pom.xml | 80 +++-- .../operator/plugins/listeners/KaffeConfig.java | 75 +++++ .../listeners/KafkaFlinkResourceListener.java | 141 ++++++++ .../flink/operator/plugins/listeners/KafkaKey.java | 25 ++ .../KafkaResourceListenerConfigOptions.java | 43 +++ .../operator/plugins/listeners/KafkaValue.java | 26 ++ ...ernetes.operator.listener.FlinkResourceListener | 1 + .../src/test/resources/log4j2-test.properties | 0 apple/examples/eks/basic-eks.yaml | 97 ++++++ apple/fluent-bit/docker/Dockerfile | 2 + apple/fluent-bit/docker/custom-parsers.conf | 12 + apple/helm/README.md | 113 +++++++ apple/helm/datalake-prod-helm-values.yaml | 17 + apple/helm/datalake-prod2-helm-values.yaml | 17 + apple/helm/datalake-qa-helm-values.yaml | 17 + .../base-eks-narrative/deployment-patch.yaml | 91 ++++++ .../flink-operator-config-patch.yaml | 86 +++++ .../base-eks-narrative/kustomization.yaml | 10 + apple/helm/kustomize/base-eks-narrative/render | 6 + .../helm/kustomize/base-eks/deployment-patch.yaml | 106 ++++++ .../base-eks/flink-operator-config-patch.yaml | 86 +++++ apple/helm/kustomize/base-eks/kustomization.yaml | 10 + apple/helm/kustomize/base-eks/render | 6 + .../helm/kustomize/base-kube/deployment-patch.yaml | 98 ++++++ apple/helm/kustomize/base-kube/kustomization.yaml | 6 + apple/helm/kustomize/base-kube/render | 6 + apple/helm/kustomize/base/kustomization.yaml | 2 + apple/helm/kustomize/base/render | 5 + .../datalake-prod/flink-operator-config-patch.yaml | 116 +++++++ .../kustomize/datalake-prod/kustomization.yaml | 11 + apple/helm/kustomize/datalake-prod/render | 6 + .../flink-operator-config-patch.yaml | 116 +++++++ .../kustomize/datalake-prod2/kustomization.yaml | 11 + apple/helm/kustomize/datalake-prod2/render | 6 + .../kustomize/datalake-qa/deployment-patch.yaml | 18 ++ .../datalake-qa/flink-operator-config-patch.yaml | 122 +++++++ .../helm/kustomize/datalake-qa/kustomization.yaml | 14 + apple/helm/kustomize/datalake-qa/render | 6 + .../helm/kustomize/fear-prod/deployment-patch.yaml | 27 ++ apple/helm/kustomize/fear-prod/kustomization.yaml | 10 + apple/helm/kustomize/fear-prod/render | 6 + apple/helm/kustomize/fear-qa/deployment-patch.yaml | 11 + apple/helm/kustomize/fear-qa/kustomization.yaml | 10 + apple/helm/kustomize/fear-qa/render | 6 + .../helm/kustomize/fear-val/deployment-patch.yaml | 27 ++ apple/helm/kustomize/fear-val/kustomization.yaml | 10 + apple/helm/kustomize/fear-val/render | 6 + .../kustomize/kafka-listener-minikube/README.md | 9 + .../kafka-listener-minikube/deployment-patch.yaml | 23 ++ .../flink-operator-config-patch.yaml | 21 ++ .../kafka-listener-minikube/kustomization.yaml | 10 + .../helm/kustomize/kafka-listener-minikube/render | 6 + .../mosaic/flink-operator-config-patch.yaml | 116 +++++++ apple/helm/kustomize/mosaic/kustomization.yaml | 11 + apple/helm/kustomize/mosaic/render | 6 + .../vpaf-prod/flink-operator-config-patch.yaml | 116 +++++++ apple/helm/kustomize/vpaf-prod/kustomization.yaml | 11 + apple/helm/kustomize/vpaf-prod/render | 6 + .../vpaf-prod2/flink-operator-config-patch.yaml | 116 +++++++ apple/helm/kustomize/vpaf-prod2/kustomization.yaml | 11 + apple/helm/kustomize/vpaf-prod2/render | 6 + .../vpaf-staging/flink-operator-config-patch.yaml | 116 +++++++ .../helm/kustomize/vpaf-staging/kustomization.yaml | 11 + apple/helm/kustomize/vpaf-staging/render | 6 + apple/helm/mosaic-helm-values.yaml | 17 + apple/helm/vpaf-prod-helm-values.yaml | 17 + apple/helm/vpaf-prod2-helm-values.yaml | 17 + apple/helm/vpaf-staging-helm-values.yaml | 17 + .../content/docs/custom-resource/job-management.md | 2 +- docs/content/docs/custom-resource/reference.md | 29 +- docs/content/docs/development/_index.md | 6 + docs/content/docs/development/roadmap.md | 41 +++ docs/content/docs/operations/compatibility.md | 2 +- docs/content/docs/operations/configuration.md | 8 +- docs/content/docs/operations/helm.md | 7 +- docs/content/docs/operations/listeners.md | 41 +++ docs/content/docs/operations/rbac.md | 6 +- docs/content/docs/operations/validator.md | 18 +- .../try-flink-kubernetes-operator/quick-start.md | 6 +- .../kubernetes_operator_config_configuration.html | 92 ++++-- .../{sessionjob-cr.yaml => multi-sessionjob.yaml} | 85 ++++- ...b_kubernetes_ha.sh => test_multi_sessionjob.sh} | 25 +- e2e-tests/test_sessionjob_operations.sh | 13 + e2e-tests/utils.sh | 15 + .../{basic-session.yaml => hpa/basic-hpa.yaml} | 31 +- examples/pod-template.yaml | 9 +- flink-kubernetes-docs/pom.xml | 2 +- flink-kubernetes-operator/pom.xml | 21 +- .../flink/kubernetes/operator/FlinkOperator.java | 139 ++++---- .../operator/artifact/ArtifactManager.java | 12 +- .../operator/config/FlinkConfigBuilder.java | 37 ++- .../operator/config/FlinkConfigManager.java | 57 ++-- .../config/FlinkOperatorConfiguration.java | 106 ++++-- .../config/KubernetesOperatorConfigOptions.java | 99 +++++- .../operator/controller/FlinkControllerConfig.java | 5 +- .../controller/FlinkDeploymentController.java | 78 ++--- .../controller/FlinkSessionJobController.java | 132 ++------ .../kubernetes/operator/crd/CrdConstants.java | 2 + .../kubernetes/operator/crd/FlinkDeployment.java | 4 +- .../operator/crd/spec/TaskManagerSpec.java | 4 + .../operator/crd/status/CommonStatus.java | 2 +- .../operator/crd/status/FlinkDeploymentStatus.java | 3 + .../operator/crd/status/ReconciliationStatus.java | 26 +- .../kubernetes/operator/crd/status/Savepoint.java | 7 +- .../operator/crd/status/SavepointInfo.java | 39 +-- ...liationState.java => SavepointTriggerType.java} | 20 +- .../{JobStatus.java => TaskManagerInfo.java} | 24 +- .../operator/listener/FlinkResourceListener.java | 65 ++++ .../operator/listener/ListenerUtils.java | 137 ++++++++ .../operator/observer/JobStatusObserver.java | 122 +++++-- .../operator/observer/SavepointFetchResult.java | 8 +- .../operator/observer/SavepointObserver.java | 174 +++++----- .../observer/context/VoidObserverContext.java | 2 +- .../deployment/AbstractDeploymentObserver.java | 117 ++++--- .../observer/deployment/ApplicationObserver.java | 69 +--- .../observer/deployment/ObserverFactory.java | 22 +- .../observer/deployment/SessionObserver.java | 21 +- .../observer/sessionjob/SessionJobObserver.java | 51 ++- .../operator/reconciler/ReconciliationUtils.java | 264 ++++++++------- .../deployment/AbstractDeploymentReconciler.java | 88 ----- .../AbstractFlinkResourceReconciler.java | 355 +++++++++++++++++++++ .../deployment/AbstractJobReconciler.java | 211 ++++++++++++ .../deployment/ApplicationReconciler.java | 266 ++++----------- .../reconciler/deployment/ReconcilerFactory.java | 12 +- .../reconciler/deployment/SessionReconciler.java | 142 +++++---- .../sessionjob/FlinkSessionJobReconciler.java | 219 ------------- .../reconciler/sessionjob/SessionJobHelper.java | 95 ------ .../sessionjob/SessionJobReconciler.java | 147 +++++++++ .../kubernetes/operator/service/FlinkService.java | 107 +++++-- .../operator/utils/ConfigOptionUtils.java | 52 +++ .../flink/kubernetes/operator/utils/EnvUtils.java | 16 + .../kubernetes/operator/utils/EventRecorder.java | 97 ++++++ .../operator/utils/EventSourceUtils.java | 152 +++++++++ .../kubernetes/operator/utils/EventUtils.java | 10 +- .../kubernetes/operator/utils/FlinkUtils.java | 24 ++ .../kubernetes/operator/utils/OperatorUtils.java | 129 -------- .../kubernetes/operator/utils/SavepointUtils.java | 144 ++++++++- .../{StatusHelper.java => StatusRecorder.java} | 74 ++++- .../operator/validation/DefaultValidator.java | 50 ++- .../src/main/resources/log4j2.properties | 3 + ...ator-assembly.xml => test-plugins-assembly.xml} | 1 + .../kubernetes/operator/FlinkOperatorTest.java | 29 +- .../flink/kubernetes/operator/TestUtils.java | 168 +++++++--- .../kubernetes/operator/TestingClusterClient.java | 12 +- .../kubernetes/operator/TestingFlinkService.java | 139 ++++---- ...tatusHelper.java => TestingStatusRecorder.java} | 14 +- .../operator/artifact/ArtifactManagerTest.java | 4 +- .../operator/config/FlinkConfigBuilderTest.java | 83 ++++- .../operator/config/FlinkConfigManagerTest.java | 34 +- .../FlinkOperatorRetryConfigurationTest.java | 85 +++++ .../controller/DeploymentRecoveryTest.java | 7 +- .../controller/FlinkDeploymentControllerTest.java | 123 +++++-- .../operator/controller/RollbackTest.java | 14 +- .../operator/informer/InformerManagerTest.java | 51 --- .../listener/FlinkResourceListenerTest.java | 114 +++++++ .../operator/listener/ListenerUtilsTest.java | 73 +++++ .../operator/listener/TestingListener.java | 71 +++++ .../operator/observer/SavepointObserverTest.java | 107 ++++++- .../deployment/ApplicationObserverTest.java | 252 ++++++++++++--- .../observer/deployment/SessionObserverTest.java | 95 +----- .../sessionjob/SessionJobObserverTest.java | 53 +-- .../deployment/ApplicationReconcilerTest.java | 86 +++-- .../deployment/SessionReconcilerTest.java | 7 +- ...ilerTest.java => SessionJobReconcilerTest.java} | 174 +++++----- .../operator/service/FlinkServiceTest.java | 24 +- .../operator/utils/ConfigOptionUtilsTest.java | 53 +++ .../kubernetes/operator/utils/EventUtilsTest.java | 6 +- .../kubernetes/operator/utils/FlinkUtilsTest.java | 19 ++ .../operator/utils/ReconciliationUtilsTest.java | 42 ++- .../operator/utils/SavepointUtilsTest.java | 84 +++++ ...atusHelperTest.java => StatusRecorderTest.java} | 8 +- .../operator/utils/ValidatorUtilsTest.java | 27 +- .../operator/validation/DefaultValidatorTest.java | 52 ++- ...rnetes.operator.listener.FlinkResourceListener} | 2 +- flink-kubernetes-shaded/pom.xml | 2 +- flink-kubernetes-webhook/pom.xml | 56 +++- .../operator/admission/AdmissionHandler.java | 31 +- .../operator/admission/FlinkOperatorWebhook.java | 15 +- .../operator/admission/FlinkValidator.java | 31 +- .../admissioncontroller/AdmissionController.java | 53 --- .../AdmissionControllerException.java | 44 --- .../admissioncontroller/AdmissionUtils.java | 66 ---- .../admissioncontroller/NotAllowedException.java | 90 ------ .../admission/admissioncontroller/Operation.java | 26 -- .../admissioncontroller/RequestHandler.java | 27 -- .../admissioncontroller/clone/Cloner.java | 30 -- .../clone/ObjectMapperCloner.java | 41 --- .../mutation/DefaultRequestMutator.java | 63 ---- .../admissioncontroller/mutation/Mutator.java | 29 -- .../validation/DefaultRequestValidator.java | 59 ---- .../admissioncontroller/validation/Validator.java | 31 -- .../admission}/informer/InformerManager.java | 109 ++++--- .../admission/mutator/DefaultRequestMutator.java | 94 ++++++ .../operator/admission/mutator/FlinkMutator.java | 71 +++++ .../src/main/resources/META-INF/NOTICE | 5 +- .../operator/admission/AdmissionHandlerTest.java | 65 +++- .../admission/informer/InformerManagerTest.java | 84 +++++ helm/flink-kubernetes-operator/Chart.yaml | 4 +- .../flink-kubernetes-operator/conf/flink-conf.yaml | 15 +- .../crds/flinkdeployments.flink.apache.org-v1.yml | 36 +++ .../crds/flinksessionjobs.flink.apache.org-v1.yml | 23 ++ .../templates/apple-network.yaml | 52 +++ .../templates/flink-operator.yaml | 23 +- .../templates/webhook.yaml | 40 ++- helm/flink-kubernetes-operator/values.yaml | 14 +- pom.xml | 43 ++- rio.yml | 74 +++++ tools/releasing/update_branch_version.sh | 6 +- 213 files changed, 7758 insertions(+), 3026 deletions(-) copy {flink-kubernetes-shaded => acs-flink-operator-plugins}/pom.xml (51%) create mode 100644 acs-flink-operator-plugins/src/main/java/com/apple/pie/flink/operator/plugins/listeners/KaffeConfig.java create mode 100644 acs-flink-operator-plugins/src/main/java/com/apple/pie/flink/operator/plugins/listeners/KafkaFlinkResourceListener.java create mode 100644 acs-flink-operator-plugins/src/main/java/com/apple/pie/flink/operator/plugins/listeners/KafkaKey.java create mode 100644 acs-flink-operator-plugins/src/main/java/com/apple/pie/flink/operator/plugins/listeners/KafkaResourceListenerConfigOptions.java create mode 100644 acs-flink-operator-plugins/src/main/java/com/apple/pie/flink/operator/plugins/listeners/KafkaValue.java create mode 100644 acs-flink-operator-plugins/src/main/resources/META-INF/services/org.apache.flink.kubernetes.operator.listener.FlinkResourceListener copy {flink-kubernetes-operator => acs-flink-operator-plugins}/src/test/resources/log4j2-test.properties (100%) create mode 100644 apple/examples/eks/basic-eks.yaml create mode 100644 apple/fluent-bit/docker/Dockerfile create mode 100644 apple/fluent-bit/docker/custom-parsers.conf create mode 100644 apple/helm/README.md create mode 100644 apple/helm/datalake-prod-helm-values.yaml create mode 100644 apple/helm/datalake-prod2-helm-values.yaml create mode 100644 apple/helm/datalake-qa-helm-values.yaml create mode 100644 apple/helm/kustomize/base-eks-narrative/deployment-patch.yaml create mode 100644 apple/helm/kustomize/base-eks-narrative/flink-operator-config-patch.yaml create mode 100644 apple/helm/kustomize/base-eks-narrative/kustomization.yaml create mode 100755 apple/helm/kustomize/base-eks-narrative/render create mode 100644 apple/helm/kustomize/base-eks/deployment-patch.yaml create mode 100644 apple/helm/kustomize/base-eks/flink-operator-config-patch.yaml create mode 100644 apple/helm/kustomize/base-eks/kustomization.yaml create mode 100755 apple/helm/kustomize/base-eks/render create mode 100644 apple/helm/kustomize/base-kube/deployment-patch.yaml create mode 100644 apple/helm/kustomize/base-kube/kustomization.yaml create mode 100755 apple/helm/kustomize/base-kube/render create mode 100644 apple/helm/kustomize/base/kustomization.yaml create mode 100755 apple/helm/kustomize/base/render create mode 100644 apple/helm/kustomize/datalake-prod/flink-operator-config-patch.yaml create mode 100644 apple/helm/kustomize/datalake-prod/kustomization.yaml create mode 100755 apple/helm/kustomize/datalake-prod/render create mode 100644 apple/helm/kustomize/datalake-prod2/flink-operator-config-patch.yaml create mode 100644 apple/helm/kustomize/datalake-prod2/kustomization.yaml create mode 100755 apple/helm/kustomize/datalake-prod2/render create mode 100644 apple/helm/kustomize/datalake-qa/deployment-patch.yaml create mode 100644 apple/helm/kustomize/datalake-qa/flink-operator-config-patch.yaml create mode 100644 apple/helm/kustomize/datalake-qa/kustomization.yaml create mode 100755 apple/helm/kustomize/datalake-qa/render create mode 100644 apple/helm/kustomize/fear-prod/deployment-patch.yaml create mode 100644 apple/helm/kustomize/fear-prod/kustomization.yaml create mode 100755 apple/helm/kustomize/fear-prod/render create mode 100644 apple/helm/kustomize/fear-qa/deployment-patch.yaml create mode 100644 apple/helm/kustomize/fear-qa/kustomization.yaml create mode 100755 apple/helm/kustomize/fear-qa/render create mode 100644 apple/helm/kustomize/fear-val/deployment-patch.yaml create mode 100644 apple/helm/kustomize/fear-val/kustomization.yaml create mode 100755 apple/helm/kustomize/fear-val/render create mode 100644 apple/helm/kustomize/kafka-listener-minikube/README.md create mode 100644 apple/helm/kustomize/kafka-listener-minikube/deployment-patch.yaml create mode 100644 apple/helm/kustomize/kafka-listener-minikube/flink-operator-config-patch.yaml create mode 100644 apple/helm/kustomize/kafka-listener-minikube/kustomization.yaml create mode 100755 apple/helm/kustomize/kafka-listener-minikube/render create mode 100644 apple/helm/kustomize/mosaic/flink-operator-config-patch.yaml create mode 100644 apple/helm/kustomize/mosaic/kustomization.yaml create mode 100755 apple/helm/kustomize/mosaic/render create mode 100644 apple/helm/kustomize/vpaf-prod/flink-operator-config-patch.yaml create mode 100644 apple/helm/kustomize/vpaf-prod/kustomization.yaml create mode 100755 apple/helm/kustomize/vpaf-prod/render create mode 100644 apple/helm/kustomize/vpaf-prod2/flink-operator-config-patch.yaml create mode 100644 apple/helm/kustomize/vpaf-prod2/kustomization.yaml create mode 100755 apple/helm/kustomize/vpaf-prod2/render create mode 100644 apple/helm/kustomize/vpaf-staging/flink-operator-config-patch.yaml create mode 100644 apple/helm/kustomize/vpaf-staging/kustomization.yaml create mode 100755 apple/helm/kustomize/vpaf-staging/render create mode 100644 apple/helm/mosaic-helm-values.yaml create mode 100644 apple/helm/vpaf-prod-helm-values.yaml create mode 100644 apple/helm/vpaf-prod2-helm-values.yaml create mode 100644 apple/helm/vpaf-staging-helm-values.yaml create mode 100644 docs/content/docs/development/roadmap.md create mode 100644 docs/content/docs/operations/listeners.md copy e2e-tests/data/{sessionjob-cr.yaml => multi-sessionjob.yaml} (60%) copy e2e-tests/{test_sessionjob_kubernetes_ha.sh => test_multi_sessionjob.sh} (74%) copy examples/{basic-session.yaml => hpa/basic-hpa.yaml} (74%) copy flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/{ReconciliationState.java => SavepointTriggerType.java} (67%) copy flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/{JobStatus.java => TaskManagerInfo.java} (71%) create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/listener/FlinkResourceListener.java create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/listener/ListenerUtils.java delete mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractDeploymentReconciler.java create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java delete mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/FlinkSessionJobReconciler.java delete mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobHelper.java create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconciler.java create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/ConfigOptionUtils.java create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventRecorder.java create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventSourceUtils.java delete mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/OperatorUtils.java rename flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/{StatusHelper.java => StatusRecorder.java} (57%) rename flink-kubernetes-operator/src/test/assembly/{test-validator-assembly.xml => test-plugins-assembly.xml} (93%) rename flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/{TestingStatusHelper.java => TestingStatusRecorder.java} (72%) create mode 100644 flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorRetryConfigurationTest.java delete mode 100644 flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/informer/InformerManagerTest.java create mode 100644 flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/listener/FlinkResourceListenerTest.java create mode 100644 flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/listener/ListenerUtilsTest.java create mode 100644 flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/listener/TestingListener.java rename flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/{FlinkSessionJobReconcilerTest.java => SessionJobReconcilerTest.java} (76%) create mode 100644 flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/ConfigOptionUtilsTest.java create mode 100644 flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/SavepointUtilsTest.java rename flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/{StatusHelperTest.java => StatusRecorderTest.java} (91%) copy flink-kubernetes-operator/src/test/resources/META-INF/services/{org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator => org.apache.flink.kubernetes.operator.listener.FlinkResourceListener} (92%) delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/AdmissionController.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/AdmissionControllerException.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/AdmissionUtils.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/NotAllowedException.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/Operation.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/RequestHandler.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/clone/Cloner.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/clone/ObjectMapperCloner.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/mutation/DefaultRequestMutator.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/mutation/Mutator.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/validation/DefaultRequestValidator.java delete mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/validation/Validator.java rename {flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator => flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission}/informer/InformerManager.java (50%) create mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/mutator/DefaultRequestMutator.java create mode 100644 flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/mutator/FlinkMutator.java create mode 100644 flink-kubernetes-webhook/src/test/java/org/apache/flink/kubernetes/operator/admission/informer/InformerManagerTest.java create mode 100644 helm/flink-kubernetes-operator/templates/apple-network.yaml create mode 100644 rio.yml