Skip to content
Browse files

remove unneeded taskbeats state in worker

  • Loading branch information...
1 parent 345cdc2 commit 7db6aa84076823939a7493218a4c310c226cc983 @nathanmarz nathanmarz committed May 17, 2012
Showing with 0 additions and 4 deletions.
  1. +0 −2 src/clj/backtype/storm/daemon/task.clj
  2. +0 −2 src/clj/backtype/storm/daemon/worker.clj
View
2 src/clj/backtype/storm/daemon/task.clj
@@ -272,8 +272,6 @@
(.join t))
(doseq [hook (.getHooks user-context)]
(.cleanup hook))
- ;; remove its taskbeats from worker if exists
- (swap! (:taskbeats worker) dissoc task-id)
(.disconnect storm-cluster-state)
(close-component task-object)
(log-message "Shut down task " storm-id ":" task-id))
View
2 src/clj/backtype/storm/daemon/worker.clj
@@ -113,7 +113,6 @@
transfer-queue (LinkedBlockingQueue.) ; possibly bound the size of it
receive-queue-map (into {} (dofor [tid task-ids] [tid (LinkedBlockingQueue.)]))
topology (read-supervisor-topology conf storm-id)
- taskbeats (atom {})
ret {:conf conf
:mq-context (if mq-context
mq-context
@@ -141,7 +140,6 @@
:transfer-queue transfer-queue
:receive-queue-map receive-queue-map
:suicide-fn (mk-suicide-fn conf)
- :taskbeats taskbeats
:uptime (uptime-computer)
}]
(merge ret

0 comments on commit 7db6aa8

Please sign in to comment.
Something went wrong with that request. Please try again.