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:54:59 UTC
[1/4] git commit: add memoized version of local-hostname in util ns
Repository: incubator-storm
Updated Branches:
refs/heads/master 3a19ccc84 -> 30efc8a53
add memoized version of local-hostname in util ns
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/a5c97d79
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/a5c97d79
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/a5c97d79
Branch: refs/heads/master
Commit: a5c97d79e0e809a43b962a8a6753f376e8bc020f
Parents: 85c9cd5
Author: Homer Strong <ho...@gmail.com>
Authored: Sun Jul 20 12:39:20 2014 -0700
Committer: Homer Strong <ho...@gmail.com>
Committed: Sun Jul 20 12:39:20 2014 -0700
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/util.clj | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/a5c97d79/storm-core/src/clj/backtype/storm/util.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/util.clj b/storm-core/src/clj/backtype/storm/util.clj
index 7c1d19e..3df25b7 100644
--- a/storm-core/src/clj/backtype/storm/util.clj
+++ b/storm-core/src/clj/backtype/storm/util.clj
@@ -204,6 +204,8 @@
[]
(.getCanonicalHostName (InetAddress/getLocalHost)))
+(def memoized-local-hostname (memoize local-hostname))
+
(letfn [(try-port [port]
(with-open [socket (java.net.ServerSocket. port)]
(.getLocalPort socket)))]
[3/4] git commit: Merge branch 'memoize-local-hostname-metrics-tick'
of https://github.com/strongh/incubator-storm into STORM-421
Posted by bo...@apache.org.
Merge branch 'memoize-local-hostname-metrics-tick' of https://github.com/strongh/incubator-storm into STORM-421
STORM-421: Memoize local hostname lookup 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/6c2f08f0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/6c2f08f0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/6c2f08f0
Branch: refs/heads/master
Commit: 6c2f08f02364f3d117db483e39450ee849d7b5ec
Parents: 3a19ccc 28de7e5
Author: Robert (Bobby) Evans <bo...@apache.org>
Authored: Fri Jul 25 13:45:14 2014 -0500
Committer: Robert (Bobby) Evans <bo...@apache.org>
Committed: Fri Jul 25 13:45:14 2014 -0500
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/executor.clj | 4 ++--
storm-core/src/clj/backtype/storm/util.clj | 2 ++
2 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
[2/4] git commit: use util/memoized-local-hostname in executor
Posted by bo...@apache.org.
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
[4/4] git commit: Updated Changelog for STORM-421
Posted by bo...@apache.org.
Updated Changelog for STORM-421
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/30efc8a5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/30efc8a5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/30efc8a5
Branch: refs/heads/master
Commit: 30efc8a53b974dbfb657ec0e13f1d82556ffbe26
Parents: 6c2f08f
Author: Robert (Bobby) Evans <bo...@apache.org>
Authored: Fri Jul 25 13:53:59 2014 -0500
Committer: Robert (Bobby) Evans <bo...@apache.org>
Committed: Fri Jul 25 13:53:59 2014 -0500
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/30efc8a5/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 366a401..b722928 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -26,6 +26,7 @@
* STORM-364: The exception time display as default timezone.
* STORM-420: Missing quotes in storm-starter python code
* STORM-399: Kafka Spout defaulting to latest offset when current offset is older then 100k
+ * STORM-421: Memoize local hostname lookup in executor
## 0.9.2-incubating
* STORM-66: send taskid on initial handshake