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/01/20 19:47:12 UTC
[2/4] storm git commit: Remove unnecessary code
Remove unnecessary code
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/fc952d4c
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/fc952d4c
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/fc952d4c
Branch: refs/heads/master
Commit: fc952d4c64f52e29cd162ffacee984ef36ab9447
Parents: 1d973c6
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Wed Jan 14 11:13:05 2015 -0600
Committer: Derek Dagit <de...@yahoo-inc.com>
Committed: Wed Jan 14 11:13:05 2015 -0600
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/nimbus.clj | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/fc952d4c/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 a7dacb8..b2cb96a 100644
--- a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
@@ -1262,9 +1262,7 @@
_ (check-authorization! nimbus storm-name topology-conf "getTopologyInfo")
task->component (storm-task-info (try-read-storm-topology conf storm-id) topology-conf)
base (.storm-base storm-cluster-state storm-id nil)
- storm-name (if base (:storm-name base) (throw (NotAliveException. (str storm-id))))
launch-time-secs (if base (:launch-time-secs base) (throw (NotAliveException. (str storm-id))))
- task->component (storm-task-info (try-read-storm-topology conf storm-id) topology-conf)
assignment (.assignment-info storm-cluster-state storm-id nil)
beats (map-val :heartbeat (get @(:heartbeats-cache nimbus) storm-id))
all-components (-> task->component reverse-map keys)