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 <programg...@163.com> 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