Issue #2: If default Zookeeper port is not available when running Local Mode, then use an arbitrary available port instead.

aptdevel · aptdevel · commit 52f051daabf6 · 2011-11-18T22:23:57.000-05:00
diff --git a/src/clj/backtype/storm/testing.clj b/src/clj/backtype/storm/testing.clj
@@ -88,7 +88,7 @@
 ;; can customize the supervisors (except for ports) by passing in map for :supervisors parameter
 ;; if need to customize amt of ports more, can use add-supervisor calls afterwards
 (defnk mk-local-storm-cluster [:supervisors 2 :ports-per-supervisor 3 :daemon-conf {}]
-  (let [zk-port 2181
+  (let [zk-port (available-port 2181)
         daemon-conf (merge (read-storm-config)
                            {TOPOLOGY-SKIP-MISSING-SERIALIZATIONS true
                             ZMQ-LINGER-MILLIS 0
diff --git a/src/clj/backtype/storm/util.clj b/src/clj/backtype/storm/util.clj
@@ -22,6 +22,17 @@
 (defn local-hostname []
   (.getCanonicalHostName (InetAddress/getLocalHost)))
 
+(letfn [(try-port [port]
+          (with-open [socket (java.net.ServerSocket. port)]
+            (.getLocalPort socket)))]
+  (defn available-port
+    ([] (try-port 0))
+    ([preferred]
+      (try
+        (try-port preferred)
+        (catch java.io.IOException e
+          (available-port))))))
+
 (defn uuid []
   (str (UUID/randomUUID)))
 
