backport disabling of slashes for topology names

Nathan Marz · Nathan Marz · commit 103806ccd360 · 2012-06-21T19:18:22.000-04:00
diff --git a/src/clj/backtype/storm/daemon/nimbus.clj b/src/clj/backtype/storm/daemon/nimbus.clj
@@ -679,6 +679,8 @@
     (reify Nimbus$Iface
       (^void submitTopology
         [this ^String storm-name ^String uploadedJarLocation ^String serializedConf ^StormTopology topology]
+        (if (.contains storm-name "/")
+          (throw (InvalidTopologyException. "Topology name cannot contains slashes")))
         (check-storm-active! nimbus storm-name false)        
         (swap! (:submitted-count nimbus) inc)
         (let [storm-id (str storm-name "-" @(:submitted-count nimbus) "-" (current-time-secs))
