[
https://issues.apache.org/jira/browse/STORM-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15144639#comment-15144639
]
ASF GitHub Bot commented on STORM-1253:
---------------------------------------
Github user jerrypeng commented on a diff in the pull request:
https://github.com/apache/storm/pull/1098#discussion_r52748470
--- Diff: storm-core/src/clj/org/apache/storm/daemon/supervisor.clj ---
@@ -332,19 +333,24 @@
:assignment-id (.getAssignmentId isupervisor)
:my-hostname (Utils/hostname conf)
:curr-assignment (atom nil) ;; used for reporting used ports when
heartbeating
- :heartbeat-timer (mk-timer :kill-fn (fn [t]
- (log-error t "Error when processing event")
- (Utils/exitProcess 20 "Error when
processing an event")
- ))
- :event-timer (mk-timer :kill-fn (fn [t]
- (log-error t "Error when
processing event")
- (Utils/exitProcess 20 "Error when
processing an event")
- ))
- :blob-update-timer (mk-timer :kill-fn (defn blob-update-timer
- [t]
- (log-error t "Error when
processing event")
- (Utils/exitProcess 20 "Error
when processing a event"))
- :timer-name "blob-update-timer")
+ :heartbeat-timer (StormTimer/mkTimer nil
+ (reify StormTimer$TimerFunc
--- End diff --
Perhaps it does, but lets try to keep things as close to the same as before
during this initial round of translation.
> port backtype.storm.timer to java
> ----------------------------------
>
> Key: STORM-1253
> URL: https://issues.apache.org/jira/browse/STORM-1253
> Project: Apache Storm
> Issue Type: New Feature
> Components: storm-core
> Reporter: Robert Joseph Evans
> Assignee: Boyang Jerry Peng
> Labels: java-migration, jstorm-merger
>
> Timer like class that uses simulated time
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
