This is an automated email from the ASF dual-hosted git repository.
gyfora pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
The following commit(s) were added to refs/heads/main by this push:
new 7e51889 [FLINK-26620] Mark CRD classes experimental
7e51889 is described below
commit 7e518898299007d8bc5019e5c477020b3460a011
Author: SteNicholas <[email protected]>
AuthorDate: Tue Mar 15 05:11:45 2022 +0800
[FLINK-26620] Mark CRD classes experimental
---
.../java/org/apache/flink/kubernetes/operator/crd/FlinkDeployment.java | 2 ++
.../org/apache/flink/kubernetes/operator/crd/FlinkDeploymentList.java | 3 +++
.../java/org/apache/flink/kubernetes/operator/crd/spec/CancelMode.java | 3 +++
.../apache/flink/kubernetes/operator/crd/spec/FlinkDeploymentSpec.java | 3 +++
.../org/apache/flink/kubernetes/operator/crd/spec/JobManagerSpec.java | 3 +++
.../java/org/apache/flink/kubernetes/operator/crd/spec/JobSpec.java | 3 +++
.../java/org/apache/flink/kubernetes/operator/crd/spec/JobState.java | 3 +++
.../java/org/apache/flink/kubernetes/operator/crd/spec/Resource.java | 3 +++
.../org/apache/flink/kubernetes/operator/crd/spec/TaskManagerSpec.java | 3 +++
.../org/apache/flink/kubernetes/operator/crd/spec/UpgradeMode.java | 3 +++
.../flink/kubernetes/operator/crd/status/FlinkDeploymentStatus.java | 2 ++
.../org/apache/flink/kubernetes/operator/crd/status/JobStatus.java | 3 +++
.../flink/kubernetes/operator/crd/status/ReconciliationStatus.java | 2 ++
.../org/apache/flink/kubernetes/operator/crd/status/Savepoint.java | 3 +++
.../org/apache/flink/kubernetes/operator/crd/status/SavepointInfo.java | 3 +++
15 files changed, 42 insertions(+)
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/FlinkDeployment.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/FlinkDeployment.java
index 2eb1bbf..cc5f3fb 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/FlinkDeployment.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/FlinkDeployment.java
@@ -17,6 +17,7 @@
package org.apache.flink.kubernetes.operator.crd;
+import org.apache.flink.annotation.Experimental;
import org.apache.flink.kubernetes.operator.crd.spec.FlinkDeploymentSpec;
import org.apache.flink.kubernetes.operator.crd.status.FlinkDeploymentStatus;
@@ -29,6 +30,7 @@ import io.fabric8.kubernetes.model.annotation.ShortNames;
import io.fabric8.kubernetes.model.annotation.Version;
/** Flink deployment object (spec + status). */
+@Experimental
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonDeserialize()
@Group("flink.apache.org")
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/FlinkDeploymentList.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/FlinkDeploymentList.java
index 21b2142..c9abd0c 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/FlinkDeploymentList.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/FlinkDeploymentList.java
@@ -17,7 +17,10 @@
package org.apache.flink.kubernetes.operator.crd;
+import org.apache.flink.annotation.Experimental;
+
import io.fabric8.kubernetes.client.CustomResourceList;
/** Multiple Flink deployments. */
+@Experimental
public class FlinkDeploymentList extends CustomResourceList<FlinkDeployment> {}
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/CancelMode.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/CancelMode.java
index 1df4f94..1cfd3b4 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/CancelMode.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/CancelMode.java
@@ -17,9 +17,12 @@
package org.apache.flink.kubernetes.operator.crd.spec;
+import org.apache.flink.annotation.Experimental;
+
import com.fasterxml.jackson.annotation.JsonProperty;
/** Enum to control Flink job cancel behavior. */
+@Experimental
public enum CancelMode {
@JsonProperty("savepoint")
SAVEPOINT,
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/FlinkDeploymentSpec.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/FlinkDeploymentSpec.java
index c3e6719..da79f3d 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/FlinkDeploymentSpec.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/FlinkDeploymentSpec.java
@@ -17,6 +17,8 @@
package org.apache.flink.kubernetes.operator.crd.spec;
+import org.apache.flink.annotation.Experimental;
+
import io.fabric8.kubernetes.api.model.Pod;
import lombok.AllArgsConstructor;
import lombok.Builder;
@@ -26,6 +28,7 @@ import lombok.NoArgsConstructor;
import java.util.Map;
/** Spec that describes a Flink application deployment. */
+@Experimental
@Data
@NoArgsConstructor
@AllArgsConstructor
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobManagerSpec.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobManagerSpec.java
index 0f81b7e..96cdf64 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobManagerSpec.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobManagerSpec.java
@@ -17,12 +17,15 @@
package org.apache.flink.kubernetes.operator.crd.spec;
+import org.apache.flink.annotation.Experimental;
+
import io.fabric8.kubernetes.api.model.Pod;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/** JobManager spec. */
+@Experimental
@Data
@NoArgsConstructor
@AllArgsConstructor
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobSpec.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobSpec.java
index 3e8bedc..1880faf 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobSpec.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobSpec.java
@@ -17,6 +17,8 @@
package org.apache.flink.kubernetes.operator.crd.spec;
+import org.apache.flink.annotation.Experimental;
+
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
@@ -24,6 +26,7 @@ import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
/** Flink job spec. */
+@Experimental
@Data
@NoArgsConstructor
@AllArgsConstructor
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobState.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobState.java
index 96d8f39..6f21df6 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobState.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobState.java
@@ -17,9 +17,12 @@
package org.apache.flink.kubernetes.operator.crd.spec;
+import org.apache.flink.annotation.Experimental;
+
import com.fasterxml.jackson.annotation.JsonProperty;
/** Enum describing the desired job state. */
+@Experimental
public enum JobState {
@JsonProperty("running")
RUNNING,
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/Resource.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/Resource.java
index c86f9a5..bf269c4 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/Resource.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/Resource.java
@@ -17,11 +17,14 @@
package org.apache.flink.kubernetes.operator.crd.spec;
+import org.apache.flink.annotation.Experimental;
+
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/** Resource spec. */
+@Experimental
@Data
@NoArgsConstructor
@AllArgsConstructor
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/TaskManagerSpec.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/TaskManagerSpec.java
index a440bf2..0453644 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/TaskManagerSpec.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/TaskManagerSpec.java
@@ -17,12 +17,15 @@
package org.apache.flink.kubernetes.operator.crd.spec;
+import org.apache.flink.annotation.Experimental;
+
import io.fabric8.kubernetes.api.model.Pod;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/** TaskManager spec. */
+@Experimental
@Data
@NoArgsConstructor
@AllArgsConstructor
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/UpgradeMode.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/UpgradeMode.java
index 58e2308..183678c 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/UpgradeMode.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/UpgradeMode.java
@@ -17,9 +17,12 @@
package org.apache.flink.kubernetes.operator.crd.spec;
+import org.apache.flink.annotation.Experimental;
+
import com.fasterxml.jackson.annotation.JsonProperty;
/** Enum to control Flink job restore behavior on upgrade/start. */
+@Experimental
public enum UpgradeMode {
@JsonProperty("savepoint")
SAVEPOINT,
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/FlinkDeploymentStatus.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/FlinkDeploymentStatus.java
index e192163..5d6cf32 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/FlinkDeploymentStatus.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/FlinkDeploymentStatus.java
@@ -17,6 +17,7 @@
package org.apache.flink.kubernetes.operator.crd.status;
+import org.apache.flink.annotation.Experimental;
import
org.apache.flink.kubernetes.operator.observer.JobManagerDeploymentStatus;
import lombok.AllArgsConstructor;
@@ -24,6 +25,7 @@ import lombok.Data;
import lombok.NoArgsConstructor;
/** Current status of the Flink deployment. */
+@Experimental
@Data
@NoArgsConstructor
@AllArgsConstructor
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/JobStatus.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/JobStatus.java
index bdb844a..4454f36 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/JobStatus.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/JobStatus.java
@@ -17,12 +17,15 @@
package org.apache.flink.kubernetes.operator.crd.status;
+import org.apache.flink.annotation.Experimental;
+
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/** Status of an individual job within the Flink deployment. */
+@Experimental
@Data
@NoArgsConstructor
@AllArgsConstructor
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/ReconciliationStatus.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/ReconciliationStatus.java
index 22dc565..9151964 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/ReconciliationStatus.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/ReconciliationStatus.java
@@ -17,6 +17,7 @@
package org.apache.flink.kubernetes.operator.crd.status;
+import org.apache.flink.annotation.Experimental;
import org.apache.flink.kubernetes.operator.crd.spec.FlinkDeploymentSpec;
import lombok.AllArgsConstructor;
@@ -25,6 +26,7 @@ import lombok.Data;
import lombok.NoArgsConstructor;
/** Status of the Flink deployment reconciliation flow. */
+@Experimental
@Data
@NoArgsConstructor
@AllArgsConstructor
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/Savepoint.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/Savepoint.java
index 6201a37..6611098 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/Savepoint.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/Savepoint.java
@@ -17,11 +17,14 @@
package org.apache.flink.kubernetes.operator.crd.status;
+import org.apache.flink.annotation.Experimental;
+
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/** Represents information about a finished savepoint. */
+@Experimental
@Data
@AllArgsConstructor
@NoArgsConstructor
diff --git
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/SavepointInfo.java
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/SavepointInfo.java
index 97f1e9a..5189a39 100644
---
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/SavepointInfo.java
+++
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/SavepointInfo.java
@@ -17,12 +17,15 @@
package org.apache.flink.kubernetes.operator.crd.status;
+import org.apache.flink.annotation.Experimental;
+
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/** Stores savepoint related information. */
+@Experimental
@Data
@NoArgsConstructor
@AllArgsConstructor
