You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/11/05 22:11:54 UTC
[2/4] storm git commit: use rmr also for worker/pids
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 <zh...@yahoo-inc.com>
Authored: Wed Nov 4 11:11:08 2015 -0600
Committer: zhuol <zh...@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)