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 11220d18eac03d5c9aca12573c5600df8b581731 Author: Kostas Kloudas <[email protected]> AuthorDate: Sat Nov 16 20:59:59 2019 +0100 [hotfix] Fix isCompatibleWith of ClusterClientFactories to ignore the case. --- .../org/apache/flink/client/deployment/StandaloneClientFactory.java | 2 +- .../src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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..b10204b 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 @@ -35,7 +35,7 @@ public class StandaloneClientFactory implements ClusterClientFactory<StandaloneC @Override public boolean isCompatibleWith(Configuration configuration) { checkNotNull(configuration); - return ID.equals(configuration.getString(DeploymentOptions.TARGET)); + return ID.equalsIgnoreCase(configuration.getString(DeploymentOptions.TARGET)); } @Override 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..7605470 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 @@ -45,7 +45,7 @@ public class YarnClusterClientFactory implements ClusterClientFactory<Applicatio @Override public boolean isCompatibleWith(Configuration configuration) { checkNotNull(configuration); - return ID.equals(configuration.getString(DeploymentOptions.TARGET)); + return ID.equalsIgnoreCase(configuration.getString(DeploymentOptions.TARGET)); } @Override
