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 0737641 Seed commit
new 7c555d2 Initial project setup
new f3d12d6 CRD alignment + first working flink deployment
new 23408e4 Basic job lifecycle handling + Spotless
new e48935c Session cluster + local debugging support
new 0fe31c5 Extract Observer and Reconciler logic from controller
new 26ca859 Adding Ingress support
new 7d640f5 Enable RAT plugin + add license headers
new 8054752 Support initialSavepointPath + do not trigger upgrade on
certain spec changes
new 5c6c128 Docker build improvements
new bfdd412 Adding basic integration test
new 5bf7973 Support pod template merging
new 2ed39cc Minor Readme updates
new 5ea10e3 Introduce FlinkService for cluster interactions
new a8cb381 Adding JobStatusObserverTest
new 411afb3 adding helm chart
new 45547d0 Make project modular + validating webhook prototype
new da6ae36 Move CRD to flink.apache.org group
new 5fae353 Add job reconciler test
new b84af25 moving to single ingress
new b6f369d provide operator log configuration via configmap
new 0b48ce0 Minor cleanups and fixes
new ce0ba97 Rework tests to avoid using mockito
new 5824296 Fix webhook helm chart
The 23 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:
.gitignore | 39 ++
Dockerfile | 50 ++
LICENSE | 201 ++++++++
README.md | 69 ++-
docker-entrypoint.sh | 40 ++
examples/basic-checkpoint-ha.yaml | 60 +++
examples/basic-ingress.yaml | 44 ++
examples/basic-session.yaml | 38 ++
examples/basic.yaml | 42 ++
examples/pod-template.yaml | 73 +++
flink-kubernetes-operator/pom.xml | 150 ++++++
.../flink/kubernetes/operator/FlinkOperator.java | 66 +++
.../controller/FlinkDeploymentController.java | 142 ++++++
.../kubernetes/operator/crd/FlinkDeployment.java | 38 ++
.../operator/crd/FlinkDeploymentList.java | 23 +
.../kubernetes/operator/crd/spec/CancelMode.java | 28 +
.../operator/crd/spec/FlinkDeploymentSpec.java | 44 ++
.../operator/crd/spec/JobManagerSpec.java | 33 ++
.../kubernetes/operator/crd/spec/JobSpec.java | 41 ++
.../kubernetes/operator/crd/spec/JobState.java | 28 +
.../kubernetes/operator/crd/spec/Resource.java | 32 ++
.../operator/crd/spec/TaskManagerSpec.java | 33 ++
.../kubernetes/operator/crd/spec/UpgradeMode.java | 30 ++
.../operator/crd/status/FlinkDeploymentStatus.java | 33 ++
.../kubernetes/operator/crd/status/JobStatus.java | 36 ++
.../operator/observer/JobStatusObserver.java | 121 +++++
.../operator/reconciler/JobReconciler.java | 170 +++++++
.../operator/reconciler/SessionReconciler.java | 78 +++
.../kubernetes/operator/service/FlinkService.java | 155 ++++++
.../kubernetes/operator/utils/FlinkUtils.java | 229 +++++++++
.../kubernetes/operator/utils/IngressUtils.java | 112 ++++
.../src/main/resources/log4j2.properties | 26 +
.../kubernetes/operator/FlinkOperatorITCase.java | 164 ++++++
.../flink/kubernetes/operator/TestUtils.java | 90 ++++
.../kubernetes/operator/TestingFlinkService.java | 100 ++++
.../operator/observer/JobStatusObserverTest.java | 74 +++
.../operator/reconciler/JobReconcilerTest.java | 87 ++++
.../kubernetes/operator/utils/FlinkUtilsTest.java | 65 +++
flink-kubernetes-webhook/pom.xml | 95 ++++
.../operator/admission/AdmissionHandler.java | 124 +++++
.../admission/FlinkDeploymentValidator.java | 53 ++
.../operator/admission/FlinkOperatorWebhook.java | 152 ++++++
.../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 | 29 ++
.../src/main/resources/log4j2.properties | 26 +
helm/flink-operator/.helmignore | 23 +
helm/flink-operator/Chart.yaml | 25 +
helm/flink-operator/templates/_helpers.tpl | 79 +++
helm/flink-operator/templates/flink-operator.yaml | 196 +++++++
helm/flink-operator/templates/ingress.yaml | 33 ++
helm/flink-operator/templates/rbac.yaml | 92 ++++
helm/flink-operator/templates/serviceaccount.yaml | 32 ++
helm/flink-operator/templates/webhook.yaml | 103 ++++
helm/flink-operator/values.yaml | 50 ++
pom.xml | 275 ++++++++++
tools/maven/checkstyle.xml | 562 +++++++++++++++++++++
tools/maven/suppressions.xml | 26 +
67 files changed, 5386 insertions(+), 1 deletion(-)
create mode 100644 .gitignore
create mode 100644 Dockerfile
create mode 100644 LICENSE
create mode 100755 docker-entrypoint.sh
create mode 100644 examples/basic-checkpoint-ha.yaml
create mode 100644 examples/basic-ingress.yaml
create mode 100644 examples/basic-session.yaml
create mode 100644 examples/basic.yaml
create mode 100644 examples/pod-template.yaml
create mode 100644 flink-kubernetes-operator/pom.xml
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/FlinkDeployment.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/FlinkDeploymentList.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/CancelMode.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/FlinkDeploymentSpec.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobManagerSpec.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobSpec.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobState.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/Resource.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/TaskManagerSpec.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/UpgradeMode.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/FlinkDeploymentStatus.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/JobStatus.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/JobReconciler.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/SessionReconciler.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/IngressUtils.java
create mode 100644
flink-kubernetes-operator/src/main/resources/log4j2.properties
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/FlinkOperatorITCase.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/TestUtils.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/TestingFlinkService.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserverTest.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/JobReconcilerTest.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/FlinkUtilsTest.java
create mode 100644 flink-kubernetes-webhook/pom.xml
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/AdmissionHandler.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/FlinkDeploymentValidator.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/FlinkOperatorWebhook.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/AdmissionController.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/AdmissionControllerException.java
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
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/Operation.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/RequestHandler.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/clone/Cloner.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/clone/ObjectMapperCloner.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/mutation/DefaultRequestMutator.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/mutation/Mutator.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/validation/DefaultRequestValidator.java
create mode 100644
flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/admissioncontroller/validation/Validator.java
create mode 100644
flink-kubernetes-webhook/src/main/resources/log4j2.properties
create mode 100644 helm/flink-operator/.helmignore
create mode 100644 helm/flink-operator/Chart.yaml
create mode 100644 helm/flink-operator/templates/_helpers.tpl
create mode 100644 helm/flink-operator/templates/flink-operator.yaml
create mode 100644 helm/flink-operator/templates/ingress.yaml
create mode 100644 helm/flink-operator/templates/rbac.yaml
create mode 100644 helm/flink-operator/templates/serviceaccount.yaml
create mode 100644 helm/flink-operator/templates/webhook.yaml
create mode 100644 helm/flink-operator/values.yaml
create mode 100644 pom.xml
create mode 100644 tools/maven/checkstyle.xml
create mode 100644 tools/maven/suppressions.xml
