You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2019/11/19 06:14:54 UTC
[flink] 05/16: [hotfix] Annotate all ClusterClientFactories as
@Internal
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 <kk...@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";