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 <[email protected]> Authored: Thu Mar 10 22:17:06 2016 +0800 Committer: xiaojian.fxj <[email protected]> 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]
