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 bf85a9d3 [doc] Doc config update
new 446961d0 [CI] Make overlapping class check more robust
new ca848f9d [FLINK-27443] Add k8s parameters and decorators for
standalone JM and TM pods
new 261fed20 [FLINK-27444] Add KubernetesStandaloneClusterDescriptor and
FlinkStandaloneKubeClient
new 0d05d0ab [FLINK-27445] Create Flink Standalone Service
new 79b16996 [FLINK-27446] Add standalone mode validation and config
building
The 5 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 | 7 +-
docs/content/docs/custom-resource/reference.md | 11 +
e2e-tests/data/flinkdep-cr.yaml | 1 +
e2e-tests/data/multi-sessionjob.yaml | 2 +
e2e-tests/data/sessionjob-cr.yaml | 1 +
.../flink/kubernetes/operator/FlinkOperator.java | 16 +-
.../operator/config/FlinkConfigBuilder.java | 74 ++-
.../operator/crd/spec/FlinkDeploymentSpec.java | 3 +
...radeMode.java => KubernetesDeploymentMode.java} | 29 +-
.../observer/deployment/ObserverFactory.java | 35 +-
.../observer/sessionjob/SessionJobObserver.java | 85 +--
.../AbstractFlinkResourceReconciler.java | 34 +-
.../deployment/AbstractJobReconciler.java | 28 +-
.../deployment/ApplicationReconciler.java | 37 +-
.../reconciler/deployment/ReconcilerFactory.java | 27 +-
.../reconciler/deployment/SessionReconciler.java | 31 +-
.../sessionjob/SessionJobReconciler.java | 27 +-
...FlinkService.java => AbstractFlinkService.java} | 510 +++++++-------
.../kubernetes/operator/service/FlinkService.java | 729 +--------------------
.../operator/service/FlinkServiceFactory.java | 73 +++
.../operator/service/NativeFlinkService.java | 161 +++++
.../operator/service/StandaloneFlinkService.java | 183 ++++++
.../operator/utils/EventSourceUtils.java | 6 +-
.../kubernetes/operator/utils/FlinkUtils.java | 139 +---
.../operator/validation/DefaultValidator.java | 36 +-
.../kubernetes/operator/TestingFlinkService.java | 34 +-
.../operator/TestingFlinkServiceFactory.java | 52 ++
.../operator/config/FlinkConfigBuilderTest.java | 85 +++
.../TestingFlinkDeploymentController.java | 8 +-
.../sessionjob/SessionJobObserverTest.java | 8 +-
.../deployment/ApplicationReconcilerTest.java | 6 +-
.../sessionjob/SessionJobReconcilerTest.java | 13 +-
...erviceTest.java => NativeFlinkServiceTest.java} | 12 +-
.../service/StandaloneFlinkServiceTest.java | 138 ++++
.../operator/validation/DefaultValidatorTest.java | 69 ++
flink-kubernetes-shaded/pom.xml | 22 +
.../pom.xml | 77 +--
.../Fabric8FlinkStandaloneKubeClient.java | 71 ++
.../kubeclient/FlinkStandaloneKubeClient.java | 12 +-
.../CmdStandaloneJobManagerDecorator.java | 90 +++
.../CmdStandaloneTaskManagerDecorator.java | 51 ++
.../InitStandaloneTaskManagerDecorator.java | 145 ++++
.../decorators/UserLibMountDecorator.java | 94 +++
.../StandaloneKubernetesJobManagerFactory.java | 124 ++++
.../StandaloneKubernetesTaskManagerFactory.java | 90 +++
.../StandaloneKubernetesJobManagerParameters.java | 91 +++
.../StandaloneKubernetesTaskManagerParameters.java | 138 ++++
.../KubernetesStandaloneClusterDescriptor.java | 257 ++++++++
.../StandaloneKubernetesConfigOptionsInternal.java | 48 ++
.../operator/utils/StandaloneKubernetesUtils.java | 64 ++
.../src/main/resources/META-INF/NOTICE | 5 +
.../Fabric8FlinkStandaloneKubeClientTest.java | 104 +++
.../CmdStandaloneJobManagerDecoratorTest.java | 106 +++
.../CmdStandaloneTaskManagerDecoratorTest.java | 64 ++
.../InitStandaloneTaskManagerDecoratorTest.java | 176 +++++
.../decorators/UserLibMountDecoratorTest.java | 126 ++++
.../StandaloneKubernetesJobManagerFactoryTest.java | 273 ++++++++
...StandaloneKubernetesTaskManagerFactoryTest.java | 150 +++++
.../kubeclient/parameters/ParametersTestBase.java | 145 ++++
...andaloneKubernetesJobManagerParametersTest.java | 105 +++
...ndaloneKubernetesTaskManagerParametersTest.java | 159 +++++
.../operator/kubeclient/utils/TestUtils.java | 92 +++
.../KubernetesStandaloneClusterDescriptorTest.java | 182 +++++
.../crds/flinkdeployments.flink.apache.org-v1.yml | 5 +
pom.xml | 6 +-
65 files changed, 4477 insertions(+), 1305 deletions(-)
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/{UpgradeMode.java
=> KubernetesDeploymentMode.java} (56%)
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/{FlinkService.java
=> AbstractFlinkService.java} (90%)
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkServiceFactory.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/NativeFlinkService.java
create mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/TestingFlinkServiceFactory.java
rename
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/{FlinkServiceTest.java
=> NativeFlinkServiceTest.java} (98%)
create mode 100644
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkServiceTest.java
copy {flink-kubernetes-webhook => flink-kubernetes-standalone}/pom.xml (55%)
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/Fabric8FlinkStandaloneKubeClient.java
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/CustomResourceMetrics.java
=>
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/FlinkStandaloneKubeClient.java
(67%)
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneTaskManagerDecorator.java
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/InitStandaloneTaskManagerDecorator.java
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/UserLibMountDecorator.java
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/factory/StandaloneKubernetesJobManagerFactory.java
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/factory/StandaloneKubernetesTaskManagerFactory.java
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesJobManagerParameters.java
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesTaskManagerParameters.java
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/standalone/KubernetesStandaloneClusterDescriptor.java
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/standalone/StandaloneKubernetesConfigOptionsInternal.java
create mode 100644
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/utils/StandaloneKubernetesUtils.java
create mode 100644
flink-kubernetes-standalone/src/main/resources/META-INF/NOTICE
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/Fabric8FlinkStandaloneKubeClientTest.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecoratorTest.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneTaskManagerDecoratorTest.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/InitStandaloneTaskManagerDecoratorTest.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/UserLibMountDecoratorTest.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/factory/StandaloneKubernetesJobManagerFactoryTest.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/factory/StandaloneKubernetesTaskManagerFactoryTest.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/ParametersTestBase.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesJobManagerParametersTest.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesTaskManagerParametersTest.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/utils/TestUtils.java
create mode 100644
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/standalone/KubernetesStandaloneClusterDescriptorTest.java
