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 <[email protected]> Authored: Wed Jan 14 11:13:05 2015 -0600 Committer: Derek Dagit <[email protected]> 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)
