storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [2/4] storm git commit: use rmr also for worker/pids
Date Thu, 05 Nov 2015 21:11:54 GMT
use rmr also for worker/pids


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/686e9061
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/686e9061
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/686e9061

Branch: refs/heads/master
Commit: 686e9061fbe921fed23b81b02faeb5965556b6b8
Parents: 8d6ab39
Author: zhuol <zhuol@yahoo-inc.com>
Authored: Wed Nov 4 11:11:08 2015 -0600
Committer: zhuol <zhuol@yahoo-inc.com>
Committed: Wed Nov 4 11:11:08 2015 -0600

----------------------------------------------------------------------
 storm-core/src/clj/backtype/storm/daemon/supervisor.clj | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/686e9061/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
index ccca370..bbda85e 100644
--- a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
@@ -243,7 +243,7 @@
           (do
             (rmr (worker-heartbeats-root conf id))
             ;; this avoids a race condition with worker or subprocess writing pid around
same time
-            (rmpath (worker-pids-root conf id))
+            (rmr (worker-pids-root conf id))
             (rmr (worker-root conf id))))
         (remove-worker-user! conf id)
         (remove-dead-worker id)


Mime
View raw message