This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a commit to branch executor-impl in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3330a3996ed66256c1752906d70418ff8a924adc Author: Kostas Kloudas <[email protected]> AuthorDate: Mon Nov 18 10:09:53 2019 +0100 [hotfix] Annotate ClusterClientFactories as @Internal --- .../java/org/apache/flink/client/deployment/ClusterClientFactory.java | 2 ++ .../org/apache/flink/client/deployment/StandaloneClientFactory.java | 2 ++ .../src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java | 2 ++ 3 files changed, 6 insertions(+) diff --git a/flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientFactory.java b/flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientFactory.java index 36647b6..3c0c5cc 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientFactory.java +++ b/flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientFactory.java @@ -18,6 +18,7 @@ package org.apache.flink.client.deployment; +import org.apache.flink.annotation.Internal; import org.apache.flink.configuration.Configuration; import javax.annotation.Nullable; @@ -25,6 +26,7 @@ import javax.annotation.Nullable; /** * A factory containing all the necessary information for creating clients to Flink clusters. */ +@Internal public interface ClusterClientFactory<ClusterID> { /** diff --git a/flink-clients/src/main/java/org/apache/flink/client/deployment/StandaloneClientFactory.java b/flink-clients/src/main/java/org/apache/flink/client/deployment/StandaloneClientFactory.java index 9597ff8..9144025 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/deployment/StandaloneClientFactory.java +++ b/flink-clients/src/main/java/org/apache/flink/client/deployment/StandaloneClientFactory.java @@ -18,6 +18,7 @@ package org.apache.flink.client.deployment; +import org.apache.flink.annotation.Internal; import org.apache.flink.client.deployment.executors.StandaloneSessionClusterExecutor; import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.DeploymentOptions; @@ -29,6 +30,7 @@ import static org.apache.flink.util.Preconditions.checkNotNull; /** * A {@link ClusterClientFactory} for a standalone cluster, i.e. Flink on bare-metal. */ +@Internal public class StandaloneClientFactory implements ClusterClientFactory<StandaloneClusterId> { public static final String ID = "default"; diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java index ad391d8..9bd1145 100644 --- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java +++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java @@ -18,6 +18,7 @@ package org.apache.flink.yarn; +import org.apache.flink.annotation.Internal; import org.apache.flink.client.deployment.ClusterClientFactory; import org.apache.flink.client.deployment.ClusterSpecification; import org.apache.flink.configuration.Configuration; @@ -40,6 +41,7 @@ import static org.apache.flink.util.Preconditions.checkNotNull; /** * A {@link ClusterClientFactory} for a YARN cluster. */ +@Internal public class YarnClusterClientFactory implements ClusterClientFactory<ApplicationId> { public static final String ID = "yarn-cluster";
