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/18 13:11:06 UTC
[flink] 10/19: [hotfix] Fix isCompatibleWith of
ClusterClientFactories to ignore the case.
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 e416017231026e804978b40fd9fe4c485d559176
Author: Kostas Kloudas <kk...@gmail.com>
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