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
discard 1ff72b3 README and doc updates for 1.0.1
discard a8b0284 [apple] enabling kafka listener in datalake-qa
discard 1cc5727 [apple] Deployment updates for release-1.1
discard 8558d98 [apple] add dc to KafkaKey
discard 5c0bc23 [apple] Datalake Prod2
discard 0d4492e [apple] move the image version to env specific values.yaml
discard e2eba2c [apple] rio version bump
discard 741bda8 [apple] Mezu secrets for EKS
discard 35cea28 [apple] upgraded FEAR clusters
discard cb0ba7b [apple] Set cluster id and cluster type as env variables
discard ea4d6d7 [apple][docker] Disable OS update on local image build
discard b789e7a [apple] Added KafkaFlinkResourceListener
discard 799441c [apple] Introduce Datalake and VPAF prod
discard c6008c0 [rio] Update for release-1.0-acs branch
discard b4acb53 [apple][rio] Add maven publish pipeline
discard 94176da [apple] added apple/helm/kustomize/fear-prod/
discard dd8dbff [apple] Rolling appender for structured logging
discard 5042e2d [apple][metrics] Improve Hubble DC on Kube
discard e6160c6 [apple] Rework AppleNetworkPolicies to use acs.flink label
discard d1c3a1a [apple] Hubble metrics for the operator
discard f5cf2f1 [apple] add base-kube with splunk
discard c008282 [apple] Watch multiple namespaces on Kube
discard 25d6e1e [apple] Pom and kustomize updates
discard 6c7abc9 [apple] added render script to apple/helm/kustomize/base/
discard 4343e59 [apple] Kube examples with kustomize
discard e3b27e3 [apple] Structured logging and podtemplate improvements
discard 62769ed [apple] Kustomize based templating for user envs
discard 534cf82 [apple] Locus Kube setup
discard 124a88f [apple] add fluent-bit custom dockerfile
discard 52a4cb8 [apple] Helm chart publish via Rio
discard ab63e3c [apple] Added internal network policy for separate sdr app
discard 9c7dd3e [apple] VPAF env
discard 20ab322 [apple] Use ACS flink version
discard 3024947 [apple] Rio build for main-acs branch
discard 36ed53d [FLINK-27280] Unify stability checking for
application/session jobs
discard fbc83c5 [FLINK-28180] Unify Application and SessionJob reconciler
logic
discard d96e852 [hotfix] Add Ingress lifecycle test
discard c3299ea [FLINK-28008] Can not get secondary resource from context
after operator restart
discard 57a5859 [FLINK-27788] Custom labels for the operator pod
discard c243b38 [FLINK-28233] Clear error status correctly for stable
deployments
discard aaf2f71 [FLINK-27912] Improve operator config names
discard 9e9b1b8 [FLINK-28166] Configurable Automatic Retries on Error
discard f421fcd [FLINK-27788] Adding annotation to k8 operator Pod
discard 16abe17 [FLINK-27820] Handle deployment errors on observe
discard 44d48e0 [FLINK-28059] Parallelize e2e tests
discard c50c0ca [FLINK-27688] Add pluggable FlinkResourceListener interface
discard 898bcec [FLINK-27812] Support Dynamic Change of Watched Namespaces
discard 1d1040b [FLINK-28087] Add validation for the meta.name of
FlinkDeployment CR
discard 4e0dd07 [hotfix] e2e test
discard 6d67821 [FLINK-27892] More than 1 secondary resource related to
primary
discard 8aec858 [FLINK-27613] Add label for the session job to help list the
session cluster
discard 708486f [FLINK-27960] Make the apt-get updating optional
discard 156105b [FLINK-27685] Add scale subresource and basic HPA support
discard f3147c7 [FLINK-27913] Remove savepointHistoryMaxCount and
savepointHistoryMaxAge from FlinkOperatorConfiguration
discard ab58abf [FLINK-27497] Track terminal job states in the observer
discard 01a3b28 [FLINK-27646] Flink Operator roadmap.md
discard 1ea5c76 [FLINK-27257] Retry failed savepoints within grace period
discard aa1c9b4 [chore] Change the session cluster not found log level to
error
discard b0ee3db Upgrading cert-manager to version 1.8.0
discard 29e615b [FLINK-26179] Support for periodic savepoints
discard 1785f6f [FLINK-27714] Migrate to java-operator-sdk v3
discard 4246e6a [FLINK-27520] Use admission-controller-framework in Webhook
discard cfddab5 [build] Add doc build for new release branch
discard 7afa8bc [hotfix] Change version of documentation in
update_branch_version.sh
discard cc9a45b [release] Update version to 1.1-SNAPSHOT
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/release-1.0 (ac50e32)
\
O -- O -- O (1ff72b3)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci.yml | 61 ++--
.github/workflows/docker-bake.hcl | 3 -
.github/workflows/docs.yaml | 12 +-
Dockerfile | 49 +--
README.md | 2 +-
acs-flink-operator-plugins/pom.xml | 120 -------
.../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 | 26 --
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 ++----
e2e-tests/data/multi-sessionjob.yaml | 186 -----------
e2e-tests/test_multi_sessionjob.sh | 50 ---
e2e-tests/test_sessionjob_operations.sh | 13 -
e2e-tests/utils.sh | 15 -
examples/hpa/basic-hpa.yaml | 37 ---
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 ++-
.../operator/crd/status/SavepointTriggerType.java | 30 --
.../operator/crd/status/TaskManagerInfo.java | 41 ---
.../operator}/informer/InformerManager.java | 109 +++----
.../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 +--------
.../{StatusRecorder.java => StatusHelper.java} | 74 +----
.../operator/validation/DefaultValidator.java | 50 +--
.../src/main/resources/log4j2.properties | 3 -
...ns-assembly.xml => test-validator-assembly.xml} | 1 -
.../kubernetes/operator/FlinkOperatorTest.java | 29 +-
.../flink/kubernetes/operator/TestUtils.java | 168 +++-------
.../kubernetes/operator/TestingClusterClient.java | 12 +-
.../kubernetes/operator/TestingFlinkService.java | 139 ++++----
...tatusRecorder.java => TestingStatusHelper.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 +-
...est.java => FlinkSessionJobReconcilerTest.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 -----
...atusRecorderTest.java => StatusHelperTest.java} | 8 +-
.../operator/utils/ValidatorUtilsTest.java | 27 +-
.../operator/validation/DefaultValidatorTest.java | 52 +--
...ernetes.operator.listener.FlinkResourceListener | 16 -
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 | 28 +-
.../admissioncontroller/AdmissionUtils.java | 66 ++++
.../admissioncontroller/NotAllowedException.java | 90 ++++++
.../admission/admissioncontroller/Operation.java | 11 +-
.../admissioncontroller/RequestHandler.java | 12 +-
.../admissioncontroller/clone/Cloner.java | 16 +-
.../clone/ObjectMapperCloner.java | 31 +-
.../mutation/DefaultRequestMutator.java | 63 ++++
.../admissioncontroller/mutation/Mutator.java | 20 +-
.../validation/DefaultRequestValidator.java | 59 ++++
.../admissioncontroller/validation/Validator.java | 32 +-
.../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, 2791 insertions(+), 8154 deletions(-)
delete mode 100644 acs-flink-operator-plugins/pom.xml
delete mode 100644
acs-flink-operator-plugins/src/main/java/com/apple/pie/flink/operator/plugins/listeners/KaffeConfig.java
delete mode 100644
acs-flink-operator-plugins/src/main/java/com/apple/pie/flink/operator/plugins/listeners/KafkaFlinkResourceListener.java
delete mode 100644
acs-flink-operator-plugins/src/main/java/com/apple/pie/flink/operator/plugins/listeners/KafkaKey.java
delete mode 100644
acs-flink-operator-plugins/src/main/java/com/apple/pie/flink/operator/plugins/listeners/KafkaResourceListenerConfigOptions.java
delete mode 100644
acs-flink-operator-plugins/src/main/java/com/apple/pie/flink/operator/plugins/listeners/KafkaValue.java
delete mode 100644
acs-flink-operator-plugins/src/main/resources/META-INF/services/org.apache.flink.kubernetes.operator.listener.FlinkResourceListener
delete mode 100644
acs-flink-operator-plugins/src/test/resources/log4j2-test.properties
delete mode 100644 apple/examples/eks/basic-eks.yaml
delete mode 100644 apple/fluent-bit/docker/Dockerfile
delete mode 100644 apple/fluent-bit/docker/custom-parsers.conf
delete mode 100644 apple/helm/README.md
delete mode 100644 apple/helm/datalake-prod-helm-values.yaml
delete mode 100644 apple/helm/datalake-prod2-helm-values.yaml
delete mode 100644 apple/helm/datalake-qa-helm-values.yaml
delete mode 100644
apple/helm/kustomize/base-eks-narrative/deployment-patch.yaml
delete mode 100644
apple/helm/kustomize/base-eks-narrative/flink-operator-config-patch.yaml
delete mode 100644 apple/helm/kustomize/base-eks-narrative/kustomization.yaml
delete mode 100755 apple/helm/kustomize/base-eks-narrative/render
delete mode 100644 apple/helm/kustomize/base-eks/deployment-patch.yaml
delete mode 100644
apple/helm/kustomize/base-eks/flink-operator-config-patch.yaml
delete mode 100644 apple/helm/kustomize/base-eks/kustomization.yaml
delete mode 100755 apple/helm/kustomize/base-eks/render
delete mode 100644 apple/helm/kustomize/base-kube/deployment-patch.yaml
delete mode 100644 apple/helm/kustomize/base-kube/kustomization.yaml
delete mode 100755 apple/helm/kustomize/base-kube/render
delete mode 100644 apple/helm/kustomize/base/kustomization.yaml
delete mode 100755 apple/helm/kustomize/base/render
delete mode 100644
apple/helm/kustomize/datalake-prod/flink-operator-config-patch.yaml
delete mode 100644 apple/helm/kustomize/datalake-prod/kustomization.yaml
delete mode 100755 apple/helm/kustomize/datalake-prod/render
delete mode 100644
apple/helm/kustomize/datalake-prod2/flink-operator-config-patch.yaml
delete mode 100644 apple/helm/kustomize/datalake-prod2/kustomization.yaml
delete mode 100755 apple/helm/kustomize/datalake-prod2/render
delete mode 100644 apple/helm/kustomize/datalake-qa/deployment-patch.yaml
delete mode 100644
apple/helm/kustomize/datalake-qa/flink-operator-config-patch.yaml
delete mode 100644 apple/helm/kustomize/datalake-qa/kustomization.yaml
delete mode 100755 apple/helm/kustomize/datalake-qa/render
delete mode 100644 apple/helm/kustomize/fear-prod/deployment-patch.yaml
delete mode 100644 apple/helm/kustomize/fear-prod/kustomization.yaml
delete mode 100755 apple/helm/kustomize/fear-prod/render
delete mode 100644 apple/helm/kustomize/fear-qa/deployment-patch.yaml
delete mode 100644 apple/helm/kustomize/fear-qa/kustomization.yaml
delete mode 100755 apple/helm/kustomize/fear-qa/render
delete mode 100644 apple/helm/kustomize/fear-val/deployment-patch.yaml
delete mode 100644 apple/helm/kustomize/fear-val/kustomization.yaml
delete mode 100755 apple/helm/kustomize/fear-val/render
delete mode 100644 apple/helm/kustomize/kafka-listener-minikube/README.md
delete mode 100644
apple/helm/kustomize/kafka-listener-minikube/deployment-patch.yaml
delete mode 100644
apple/helm/kustomize/kafka-listener-minikube/flink-operator-config-patch.yaml
delete mode 100644
apple/helm/kustomize/kafka-listener-minikube/kustomization.yaml
delete mode 100755 apple/helm/kustomize/kafka-listener-minikube/render
delete mode 100644 apple/helm/kustomize/mosaic/flink-operator-config-patch.yaml
delete mode 100644 apple/helm/kustomize/mosaic/kustomization.yaml
delete mode 100755 apple/helm/kustomize/mosaic/render
delete mode 100644
apple/helm/kustomize/vpaf-prod/flink-operator-config-patch.yaml
delete mode 100644 apple/helm/kustomize/vpaf-prod/kustomization.yaml
delete mode 100755 apple/helm/kustomize/vpaf-prod/render
delete mode 100644
apple/helm/kustomize/vpaf-prod2/flink-operator-config-patch.yaml
delete mode 100644 apple/helm/kustomize/vpaf-prod2/kustomization.yaml
delete mode 100755 apple/helm/kustomize/vpaf-prod2/render
delete mode 100644
apple/helm/kustomize/vpaf-staging/flink-operator-config-patch.yaml
delete mode 100644 apple/helm/kustomize/vpaf-staging/kustomization.yaml
delete mode 100755 apple/helm/kustomize/vpaf-staging/render
delete mode 100644 apple/helm/mosaic-helm-values.yaml
delete mode 100644 apple/helm/vpaf-prod-helm-values.yaml
delete mode 100644 apple/helm/vpaf-prod2-helm-values.yaml
delete mode 100644 apple/helm/vpaf-staging-helm-values.yaml
delete mode 100644 docs/content/docs/development/roadmap.md
delete mode 100644 docs/content/docs/operations/listeners.md
delete mode 100644 e2e-tests/data/multi-sessionjob.yaml
delete mode 100755 e2e-tests/test_multi_sessionjob.sh
delete mode 100644 examples/hpa/basic-hpa.yaml
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/SavepointTriggerType.java
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/TaskManagerInfo.java
rename
{flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission
=>
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator}/informer/InformerManager.java
(50%)
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/listener/FlinkResourceListener.java
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/listener/ListenerUtils.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractDeploymentReconciler.java
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/FlinkSessionJobReconciler.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobHelper.java
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconciler.java
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/ConfigOptionUtils.java
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventRecorder.java
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventSourceUtils.java
create 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/{StatusRecorder.java
=> StatusHelper.java} (57%)
rename flink-kubernetes-operator/src/test/assembly/{test-plugins-assembly.xml
=> test-validator-assembly.xml} (93%)
rename
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/{TestingStatusRecorder.java
=> TestingStatusHelper.java} (72%)
delete mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorRetryConfigurationTest.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/informer/InformerManagerTest.java
delete mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/listener/FlinkResourceListenerTest.java
delete mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/listener/ListenerUtilsTest.java
delete 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/{SessionJobReconcilerTest.java
=> FlinkSessionJobReconcilerTest.java} (76%)
delete mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/ConfigOptionUtilsTest.java
delete 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/{StatusRecorderTest.java
=> StatusHelperTest.java} (91%)
delete mode 100644
flink-kubernetes-operator/src/test/resources/META-INF/services/org.apache.flink.kubernetes.operator.listener.FlinkResourceListener
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/AdmissionController.java
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/exception/ReconciliationException.java
=>
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/AdmissionControllerException.java
(51%)
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/AdmissionUtils.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/NotAllowedException.java
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/context/VoidObserverContext.java
=>
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/Operation.java
(76%)
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/CustomResourceMetrics.java
=>
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/RequestHandler.java
(66%)
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/Observer.java
=>
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/clone/Cloner.java
(64%)
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/FlinkDeploymentReconciliationStatus.java
=>
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/clone/ObjectMapperCloner.java
(51%)
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/mutation/DefaultRequestMutator.java
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobState.java
=>
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/mutation/Mutator.java
(59%)
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/validation/DefaultRequestValidator.java
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/IngressSpec.java
=>
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/validation/Validator.java
(55%)
delete mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/mutator/DefaultRequestMutator.java
delete mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/mutator/FlinkMutator.java
delete mode 100644
flink-kubernetes-webhook/src/test/java/org/apache/flink/kubernetes/operator/admission/informer/InformerManagerTest.java
delete mode 100644 helm/flink-kubernetes-operator/templates/apple-network.yaml
delete mode 100644 rio.yml
