You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/05/15 20:02:49 UTC
[07/13] storm git commit: made changes for adding the supervisor-info
version
made changes for adding the supervisor-info version
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/670d93e9
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/670d93e9
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/670d93e9
Branch: refs/heads/0.10.x-branch
Commit: 670d93e98ef66ecff342c44f31a1df7f2709c13b
Parents: ebb9634
Author: sanket <sc...@yahoo-inc.com>
Authored: Fri Apr 17 15:34:05 2015 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri May 15 13:42:10 2015 -0400
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/common.clj | 2 +-
storm-core/src/clj/backtype/storm/daemon/nimbus.clj | 1 -
2 files changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/670d93e9/storm-core/src/clj/backtype/storm/daemon/common.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/common.clj b/storm-core/src/clj/backtype/storm/daemon/common.clj
index a5da665..e3a10ef 100644
--- a/storm-core/src/clj/backtype/storm/daemon/common.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/common.clj
@@ -53,7 +53,7 @@
;; component->executors is a map from spout/bolt id to number of executors for that component
(defrecord StormBase [storm-name launch-time-secs status num-workers component->executors owner topology-action-options prev-status])
-(defrecord SupervisorInfo [time-secs hostname assignment-id used-ports meta scheduler-meta uptime-secs version-info])
+(defrecord SupervisorInfo [time-secs hostname assignment-id used-ports meta scheduler-meta uptime-secs version])
(defprotocol DaemonCommon
(waiting? [this]))
http://git-wip-us.apache.org/repos/asf/storm/blob/670d93e9/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
index 4bad1ee..5d0a0f2 100644
--- a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
@@ -1253,7 +1253,6 @@
(count (:used-ports info))
id
(:version info))
- (log-message "supervisor-version " :version info)
))
nimbus-uptime ((:uptime nimbus))
bases (topology-bases storm-cluster-state)