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 c406db0d [FLINK-29819] Record an error event when savepoint fails
within grace period
new a7e6f0c8 [FLINK-29655] Split Flink CRD from flink-kubernates-operator
module
new 211a326a [FLINK-29655] Eliminate unnecessary dependencies from CRD API
module
new b4bef2b9 [FLINK-29655] Move api module contents to matching package
The 3 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:
docs/content/docs/custom-resource/reference.md | 98 +++---
.../main/java/org/apache/flink/examples/Basic.java | 16 +-
.../pom.xml | 370 +++++----------------
.../operator/api}/AbstractFlinkResource.java | 6 +-
.../kubernetes/operator/api}/CrdConstants.java | 2 +-
.../kubernetes/operator/api}/FlinkDeployment.java | 6 +-
.../operator/api}/FlinkDeploymentList.java | 2 +-
.../kubernetes/operator/api}/FlinkSessionJob.java | 6 +-
.../operator/api}/FlinkSessionJobList.java | 2 +-
.../kubernetes/operator/api}/diff/DiffType.java | 2 +-
.../kubernetes/operator/api}/diff/Diffable.java | 7 +-
.../kubernetes/operator/api}/diff/SpecDiff.java | 2 +-
.../operator/api}/docs/CrdReferenceDoclet.java | 6 +-
.../api}/reconciler/ReconciliationMetadata.java | 8 +-
.../operator/api}/spec/AbstractFlinkSpec.java | 19 +-
.../operator/api}/spec/FlinkDeploymentSpec.java | 2 +-
.../operator/api}/spec/FlinkSessionJobSpec.java | 2 +-
.../operator/api}/spec/FlinkVersion.java | 2 +-
.../kubernetes/operator/api}/spec/IngressSpec.java | 2 +-
.../operator/api}/spec/JobManagerSpec.java | 2 +-
.../kubernetes/operator/api}/spec/JobSpec.java | 15 +-
.../kubernetes/operator/api}/spec/JobState.java | 2 +-
.../api}/spec/KubernetesDeploymentMode.java | 4 +-
.../kubernetes/operator/api}/spec/Resource.java | 2 +-
.../operator/api}/spec/TaskManagerSpec.java | 2 +-
.../kubernetes/operator/api}/spec/UpgradeMode.java | 2 +-
.../operator/api/status/CommonStatus.java | 27 +-
.../FlinkDeploymentReconciliationStatus.java | 4 +-
.../api}/status/FlinkDeploymentStatus.java | 4 +-
.../FlinkSessionJobReconciliationStatus.java | 4 +-
.../api}/status/FlinkSessionJobStatus.java | 4 +-
.../api/status/JobManagerDeploymentStatus.java | 35 +-
.../kubernetes/operator/api}/status/JobStatus.java | 2 +-
.../operator/api}/status/ReconciliationState.java | 2 +-
.../operator/api}/status/ReconciliationStatus.java | 25 +-
.../kubernetes/operator/api}/status/Savepoint.java | 2 +-
.../operator/api}/status/SavepointFormatType.java | 2 +-
.../operator/api}/status/SavepointInfo.java | 2 +-
.../operator/api}/status/SavepointTriggerType.java | 2 +-
.../operator/api}/status/TaskManagerInfo.java | 2 +-
.../kubernetes/operator/api/utils/SpecUtils.java | 123 +++++++
.../operator/api/utils/SpecWithMeta.java | 23 +-
.../api}/validation/CrdCompatibilityChecker.java | 2 +-
.../src/main/resources/log4j2.properties | 0
.../operator/api/utils/BaseTestUtils.java | 170 ++++++++++
.../operator/api/utils/SpecUtilsTest.java | 59 ++++
.../validation/CrdCompatibilityCheckerTest.java | 6 +-
flink-kubernetes-operator/pom.xml | 110 +-----
.../operator/artifact/ArtifactManager.java | 2 +-
.../operator/config/FlinkConfigBuilder.java | 14 +-
.../operator/config/FlinkConfigManager.java | 8 +-
.../config/FlinkOperatorConfiguration.java | 10 +-
.../flink/kubernetes/operator/config/Mode.java | 4 +-
.../controller/FlinkDeploymentController.java | 6 +-
.../controller/FlinkSessionJobController.java | 6 +-
.../operator/crd/status/CommonStatus.java | 91 -----
.../crd/status/JobManagerDeploymentStatus.java | 71 ----
.../kubernetes/operator/listener/AuditUtils.java | 10 +-
.../operator/listener/FlinkResourceListener.java | 12 +-
.../operator/metrics/FlinkDeploymentMetrics.java | 4 +-
.../operator/metrics/FlinkSessionJobMetrics.java | 2 +-
.../metrics/KubernetesOperatorMetricGroup.java | 2 +-
.../kubernetes/operator/metrics/MetricManager.java | 6 +-
.../operator/metrics/OperatorJosdkMetrics.java | 6 +-
.../operator/metrics/OperatorMetricUtils.java | 44 +++
.../metrics/lifecycle/LifecycleMetrics.java | 8 +-
.../observer/AbstractFlinkResourceObserver.java | 4 +-
.../operator/observer/ClusterHealthObserver.java | 2 +-
.../operator/observer/JobStatusObserver.java | 4 +-
.../operator/observer/SavepointObserver.java | 10 +-
.../AbstractFlinkDeploymentObserver.java | 12 +-
.../observer/deployment/ApplicationObserver.java | 6 +-
.../deployment/FlinkDeploymentObserverContext.java | 2 +-
.../deployment/FlinkDeploymentObserverFactory.java | 6 +-
.../observer/deployment/SessionObserver.java | 4 +-
.../sessionjob/FlinkSessionJobObserver.java | 6 +-
.../sessionjob/FlinkSessionJobObserverContext.java | 4 +-
.../operator/reconciler/ReconciliationUtils.java | 169 ++++------
.../AbstractFlinkResourceReconciler.java | 23 +-
.../deployment/AbstractJobReconciler.java | 16 +-
.../deployment/ApplicationReconciler.java | 12 +-
.../reconciler/deployment/ReconcilerFactory.java | 6 +-
.../reconciler/deployment/SessionReconciler.java | 16 +-
.../kubernetes/operator/reconciler/diff/Diff.java | 2 +
.../operator/reconciler/diff/DiffBuilder.java | 4 +-
.../operator/reconciler/diff/DiffResult.java | 2 +
.../reconciler/diff/ReflectiveDiffBuilder.java | 12 +-
.../sessionjob/SessionJobReconciler.java | 14 +-
.../operator/service/AbstractFlinkService.java | 22 +-
.../kubernetes/operator/service/FlinkService.java | 19 +-
.../operator/service/FlinkServiceFactory.java | 4 +-
.../operator/service/NativeFlinkService.java | 10 +-
.../operator/service/StandaloneFlinkService.java | 8 +-
.../kubernetes/operator/utils/EventRecorder.java | 4 +-
.../operator/utils/EventSourceUtils.java | 4 +-
.../utils/FlinkResourceExceptionUtils.java | 2 +-
.../kubernetes/operator/utils/FlinkUtils.java | 4 +-
.../kubernetes/operator/utils/IngressUtils.java | 2 +-
.../kubernetes/operator/utils/SavepointUtils.java | 10 +-
.../kubernetes/operator/utils/StatusRecorder.java | 14 +-
.../operator/validation/DefaultValidator.java | 28 +-
.../validation/FlinkResourceValidator.java | 4 +-
.../kubernetes/operator/FlinkOperatorITCase.java | 12 +-
.../flink/kubernetes/operator/TestUtils.java | 156 +--------
.../kubernetes/operator/TestingFlinkService.java | 22 +-
.../operator/TestingFlinkServiceFactory.java | 4 +-
.../kubernetes/operator/TestingStatusRecorder.java | 4 +-
.../operator/config/FlinkConfigBuilderTest.java | 20 +-
.../operator/config/FlinkConfigManagerTest.java | 4 +-
.../controller/DeploymentRecoveryTest.java | 8 +-
.../controller/FailedDeploymentRestartTest.java | 8 +-
.../controller/FlinkDeploymentControllerTest.java | 48 +--
.../operator/controller/RollbackTest.java | 16 +-
.../TestingFlinkDeploymentController.java | 4 +-
.../controller/UnhealthyDeploymentRestartTest.java | 8 +-
.../listener/FlinkResourceListenerTest.java | 6 +-
.../operator/listener/TestingListener.java | 8 +-
.../metrics/FlinkDeploymentMetricsTest.java | 4 +-
.../metrics/FlinkSessionJobMetricsTest.java | 2 +-
.../metrics/KubernetesOperatorMetricGroupTest.java | 2 +-
.../operator/metrics/OperatorJosdkMetricsTest.java | 2 +-
.../operator/metrics/TestingMetricListener.java | 2 +-
.../lifecycle/ResourceLifecycleMetricsTest.java | 30 +-
.../operator/observer/SavepointObserverTest.java | 12 +-
.../deployment/ApplicationObserverTest.java | 25 +-
.../observer/deployment/SessionObserverTest.java | 10 +-
.../sessionjob/FlinkSessionJobObserverTest.java | 8 +-
.../deployment/ApplicationReconcilerTest.java | 30 +-
.../ApplicationReconcilerUpgradeModeTest.java | 20 +-
.../deployment/SessionReconcilerTest.java | 10 +-
.../operator/reconciler/diff/SpecDiffTest.java | 67 ++--
.../sessionjob/SessionJobReconcilerTest.java | 14 +-
.../operator/service/NativeFlinkServiceTest.java | 14 +-
.../service/StandaloneFlinkServiceTest.java | 6 +-
.../kubernetes/operator/utils/EventCollector.java | 2 +-
.../utils/FlinkResourceExceptionUtilsTest.java | 8 +-
.../operator/utils/IngressUtilsTest.java | 4 +-
.../operator/utils/ReconciliationUtilsTest.java | 44 +--
.../operator/utils/SavepointUtilsTest.java | 8 +-
.../operator/utils/StatusRecorderTest.java | 6 +-
.../operator/validation/DefaultValidatorTest.java | 32 +-
.../operator/validation/TestValidator.java | 4 +-
.../operator/admission/FlinkValidator.java | 6 +-
.../admission/informer/InformerManager.java | 2 +-
.../operator/admission/mutator/FlinkMutator.java | 4 +-
.../operator/admission/AdmissionHandlerTest.java | 12 +-
pom.xml | 6 +-
147 files changed, 1219 insertions(+), 1481 deletions(-)
copy {flink-kubernetes-operator => flink-kubernetes-operator-api}/pom.xml (51%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/AbstractFlinkResource.java
(87%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/CrdConstants.java
(96%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/FlinkDeployment.java
(91%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/FlinkDeploymentList.java
(96%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/FlinkSessionJob.java
(90%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/FlinkSessionJobList.java
(96%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/diff/DiffType.java
(95%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/diff/Diffable.java
(88%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/diff/SpecDiff.java
(96%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/docs/CrdReferenceDoclet.java
(98%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/reconciler/ReconciliationMetadata.java
(90%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/AbstractFlinkSpec.java
(69%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/FlinkDeploymentSpec.java
(97%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/FlinkSessionJobSpec.java
(96%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/FlinkVersion.java
(95%)
copy
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/IngressSpec.java
(96%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/JobManagerSpec.java
(96%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/JobSpec.java
(82%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/JobState.java
(95%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/KubernetesDeploymentMode.java
(93%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/Resource.java
(95%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/TaskManagerSpec.java
(96%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/spec/UpgradeMode.java
(96%)
copy
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/FlinkSessionJobStatus.java
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/CommonStatus.java
(59%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/FlinkDeploymentReconciliationStatus.java
(91%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/FlinkDeploymentStatus.java
(94%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/FlinkSessionJobReconciliationStatus.java
(91%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/FlinkSessionJobStatus.java
(92%)
rename
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/IngressSpec.java
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/JobManagerDeploymentStatus.java
(54%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/JobStatus.java
(96%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/ReconciliationState.java
(95%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/ReconciliationStatus.java
(75%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/Savepoint.java
(97%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/SavepointFormatType.java
(95%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/SavepointInfo.java
(98%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/SavepointTriggerType.java
(95%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/status/TaskManagerInfo.java
(96%)
create mode 100644
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/utils/SpecUtils.java
copy examples/flink-sql-runner-example/sql-scripts/simple.sql =>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/utils/SpecWithMeta.java
(64%)
rename
{flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator
=>
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api}/validation/CrdCompatibilityChecker.java
(99%)
copy {flink-kubernetes-operator =>
flink-kubernetes-operator-api}/src/main/resources/log4j2.properties (100%)
create mode 100644
flink-kubernetes-operator-api/src/test/java/org/apache/flink/kubernetes/operator/api/utils/BaseTestUtils.java
create mode 100644
flink-kubernetes-operator-api/src/test/java/org/apache/flink/kubernetes/operator/api/utils/SpecUtilsTest.java
rename
{flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator
=>
flink-kubernetes-operator-api/src/test/java/org/apache/flink/kubernetes/operator/api}/validation/CrdCompatibilityCheckerTest.java
(98%)
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/CommonStatus.java
delete mode 100644
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/JobManagerDeploymentStatus.java
