[hotfix] Rename AbstractClusterClientFactory to AbstractContainerized…

…ClusterClientFactory.
mbalassi · Jan 6, 2020 · 3285f7d · 3285f7d
1 parent a455ddf
commit 3285f7d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/...loyment/AbstractClusterClientFactory.java → ...actContainerizedClusterClientFactory.java b/...loyment/AbstractClusterClientFactory.java → ...actContainerizedClusterClientFactory.java
@@ -27,10 +27,10 @@
 import static org.apache.flink.util.Preconditions.checkNotNull;
 
 /**
- * An abstract {@link ClusterClientFactory} containing some common implementations for different deployment clusters.
+ * An abstract {@link ClusterClientFactory} containing some common implementations for different containerized deployment clusters.
  */
 @Internal
-public abstract class AbstractClusterClientFactory<ClusterID> implements ClusterClientFactory<ClusterID> {
+public abstract class AbstractContainerizedClusterClientFactory<ClusterID> implements ClusterClientFactory<ClusterID> {
 
  @Override
  public ClusterSpecification getClusterSpecification(Configuration configuration) {

diff --git a/...-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterClientFactory.java b/...-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterClientFactory.java
@@ -19,7 +19,7 @@
 package org.apache.flink.kubernetes;
 
 import org.apache.flink.annotation.Internal;
-import org.apache.flink.client.deployment.AbstractClusterClientFactory;
+import org.apache.flink.client.deployment.AbstractContainerizedClusterClientFactory;
 import org.apache.flink.client.deployment.ClusterClientFactory;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.DeploymentOptions;
@@ -37,7 +37,7 @@
  * A {@link ClusterClientFactory} for a Kubernetes cluster.
  */
 @Internal
-public class KubernetesClusterClientFactory extends AbstractClusterClientFactory<String> {
+public class KubernetesClusterClientFactory extends AbstractContainerizedClusterClientFactory<String> {
 
  private static final String CLUSTER_ID_PREFIX = "flink-cluster-";
 

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
@@ -19,7 +19,7 @@
 package org.apache.flink.yarn;
 
 import org.apache.flink.annotation.Internal;
-import org.apache.flink.client.deployment.AbstractClusterClientFactory;
+import org.apache.flink.client.deployment.AbstractContainerizedClusterClientFactory;
 import org.apache.flink.client.deployment.ClusterClientFactory;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.DeploymentOptions;
@@ -40,7 +40,7 @@
  * A {@link ClusterClientFactory} for a YARN cluster.
  */
 @Internal
-public class YarnClusterClientFactory extends AbstractClusterClientFactory<ApplicationId> {
+public class YarnClusterClientFactory extends AbstractContainerizedClusterClientFactory<ApplicationId> {
 
  @Override
  public boolean isCompatibleWith(Configuration configuration) {