[MINOR] makes the exception message more clear in StormSubmitter
diff --git a/storm-client/src/jvm/org/apache/storm/StormSubmitter.java b/storm-client/src/jvm/org/apache/storm/StormSubmitter.java
index d391784..f782272 100644
--- a/storm-client/src/jvm/org/apache/storm/StormSubmitter.java
+++ b/storm-client/src/jvm/org/apache/storm/StormSubmitter.java
@@ -252,8 +252,8 @@
try {
String serConf = JSONValue.toJSONString(topoConf);
try (NimbusClient client = NimbusClient.getConfiguredClientAs(conf, asUser)) {
- if (isTopologyNameAllowed(name, client)) {
- throw new RuntimeException("Topology with name `" + name + "` is either not allowed or it already exists on cluster");
+ if (!isTopologyNameAllowed(name, client)) {
+ throw new RuntimeException("Topology name " + name + " is either not allowed or it already exists on the cluster");
}
// Dependency uploading only makes sense for distributed mode
@@ -438,7 +438,7 @@
private static boolean isTopologyNameAllowed(String name, NimbusClient client) {
try {
- return !client.getClient().isTopologyNameAllowed(name);
+ return client.getClient().isTopologyNameAllowed(name);
} catch (Exception e) {
throw new RuntimeException(e);
}
