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 2016/04/01 16:07:33 UTC
[10/35] storm git commit: sdf
sdf
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/184dc4a5
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/184dc4a5
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/184dc4a5
Branch: refs/heads/master
Commit: 184dc4a5c3fa8c9662ab224a82f33cc687b95c4b
Parents: 465a4b8
Author: xiaojian.fxj <xi...@alibaba-inc.com>
Authored: Thu Mar 10 22:17:06 2016 +0800
Committer: xiaojian.fxj <xi...@alibaba-inc.com>
Committed: Thu Mar 10 22:17:06 2016 +0800
----------------------------------------------------------------------
storm-core/src/clj/org/apache/storm/daemon/local_supervisor.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/184dc4a5/storm-core/src/clj/org/apache/storm/daemon/local_supervisor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/org/apache/storm/daemon/local_supervisor.clj b/storm-core/src/clj/org/apache/storm/daemon/local_supervisor.clj
index 70c280a..2361817 100644
--- a/storm-core/src/clj/org/apache/storm/daemon/local_supervisor.clj
+++ b/storm-core/src/clj/org/apache/storm/daemon/local_supervisor.clj
@@ -34,7 +34,7 @@
workerId)]
(ConfigUtils/setWorkerUserWSE conf workerId "")
(ProcessSimulator/registerProcess pid worker)
- (.put (.getWorkerThreadPidsAtom supervisorData) workerId pid)
+ (.put (.getWorkerThreadPids supervisorData) workerId pid)
))
(defn shutdown-local-worker [supervisorData workerId]