You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gy...@apache.org on 2022/06/27 12:01:30 UTC
[flink-kubernetes-operator] branch release-1.0 updated (ac50e32 -> 1ff72b3)
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