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 2014/07/25 20:55:00 UTC
[2/4] git commit: use util/memoized-local-hostname in executor
use util/memoized-local-hostname in executor
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/28de7e51
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/28de7e51
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/28de7e51
Branch: refs/heads/master
Commit: 28de7e511340d6c134f2eac039dc054a0107cba4
Parents: a5c97d7
Author: Homer Strong <ho...@gmail.com>
Authored: Sun Jul 20 12:39:40 2014 -0700
Committer: Homer Strong <ho...@gmail.com>
Committed: Sun Jul 20 12:39:40 2014 -0700
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/executor.clj | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/28de7e51/storm-core/src/clj/backtype/storm/daemon/executor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/executor.clj b/storm-core/src/clj/backtype/storm/daemon/executor.clj
index 890a01e..f60aa80 100644
--- a/storm-core/src/clj/backtype/storm/daemon/executor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/executor.clj
@@ -176,7 +176,7 @@
(when (<= @interval-errors max-per-interval)
(cluster/report-error (:storm-cluster-state executor) (:storm-id executor) (:component-id executor)
- (local-hostname) (.getThisWorkerPort (:worker-context executor)) error)
+ (memoized-local-hostname) (.getThisWorkerPort (:worker-context executor)) error)
))))
;; in its own function so that it can be mocked out by tracked topologies
@@ -278,7 +278,7 @@
task-id (:task-id task-data)
name->imetric (-> interval->task->metric-registry (get interval) (get task-id))
task-info (IMetricsConsumer$TaskInfo.
- (. (java.net.InetAddress/getLocalHost) getCanonicalHostName)
+ (memoized-local-hostname)
(.getThisWorkerPort worker-context)
(:component-id executor-data)
task-id