this section of code was moved to new PR

smtp2006 · Mar 26, 2013 · 4bc5f51 · 4bc5f51
1 parent c6cbcfc
commit 4bc5f51
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/src/clj/backtype/storm/daemon/supervisor.clj b/src/clj/backtype/storm/daemon/supervisor.clj
@@ -117,12 +117,7 @@
 (defn- wait-for-worker-launch [conf id start-time]
   (let [state (worker-state conf id)]    
     (loop []
-      (let [hb (try (.get state LS-WORKER-HEARTBEAT)
-                    (catch java.io.FileNotFoundException e
-                      ;; This solves race condition in unit tests if you try to shutdown
-                      ;; a worker which cleans up worker state while you also try to wait
-                      ;; for worker to launch by reading the same state.
-                      nil))]
+      (let [hb (.get state LS-WORKER-HEARTBEAT)]
         (when (and
                (not hb)
                (<