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 2014/11/26 23:34:45 UTC
[07/21] storm git commit: STORM-558 change "swap!" to "reset!" to fix
assignment-versions always empty in supervisor
STORM-558 change "swap!" to "reset!" to fix assignment-versions always
empty in supervisor
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/04e6ebf4
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/04e6ebf4
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/04e6ebf4
Branch: refs/heads/master
Commit: 04e6ebf44de44ff28e96c67fa36f2bbc576051c7
Parents: c81b2cb
Author: Kang Xiao <kx...@gmail.com>
Authored: Mon Nov 17 15:29:15 2014 +0800
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Mon Nov 17 15:28:13 2014 -0500
----------------------------------------------------------------------
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/04e6ebf4/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 71f9bfb..820379e 100644
--- a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
@@ -364,7 +364,7 @@
(.put local-state
LS-LOCAL-ASSIGNMENTS
new-assignment)
- (swap! (:assignment-versions supervisor) versions)
+ (reset! (:assignment-versions supervisor) versions)
(reset! (:curr-assignment supervisor) new-assignment)
;; remove any downloaded code that's no longer assigned or active
;; important that this happens after setting the local assignment so that