This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a commit to branch executors-clean in repository https://gitbox.apache.org/repos/asf/flink.git
commit 30e3090c6c51dacd1762db16ad3c80c8d442ffa8 Author: Kostas Kloudas <kklou...@gmail.com> AuthorDate: Mon Nov 18 14:27:05 2019 +0100 [hotfix] Annotate all 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 b441a63..f71563e 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.configuration.Configuration; import org.apache.flink.configuration.DeploymentOptions; @@ -28,6 +29,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 aa138a7..156790f 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; @@ -38,6 +39,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";