You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2015/03/08 18:52:08 UTC
[1/2] storm git commit: STORM-496. task.clj missing debug for logging
spout and bolt emit values.
Repository: storm
Updated Branches:
refs/heads/master 9f57ba9bb -> 9517923b1
STORM-496. task.clj missing debug for logging spout and bolt emit values.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/31933077
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/31933077
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/31933077
Branch: refs/heads/master
Commit: 3193307777b3155dc1524af0316aee139f349b23
Parents: 182a734
Author: Sriharsha Chintalapani <ma...@harsha.io>
Authored: Thu Feb 26 08:02:25 2015 -0800
Committer: Sriharsha Chintalapani <ma...@harsha.io>
Committed: Thu Feb 26 08:02:25 2015 -0800
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/task.clj | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/31933077/storm-core/src/clj/backtype/storm/daemon/task.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/task.clj b/storm-core/src/clj/backtype/storm/daemon/task.clj
index b037d21..da4abb3 100644
--- a/storm-core/src/clj/backtype/storm/daemon/task.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/task.clj
@@ -132,9 +132,12 @@
emit-sampler (mk-stats-sampler storm-conf)
stream->component->grouper (:stream->component->grouper executor-data)
user-context (:user-context task-data)
- executor-stats (:stats executor-data)]
+ executor-stats (:stats executor-data)
+ debug? (= true (storm-conf TOPOLOGY-DEBUG))]
(fn ([^Integer out-task-id ^String stream ^List values]
+ (when debug?
+ (log-message "Emitting direct: " out-task-id "; " component-id " " stream " " values))
(let [target-component (.getComponentId worker-context out-task-id)
component->grouping (get stream->component->grouper stream)
grouping (get component->grouping target-component)
@@ -151,6 +154,8 @@
(if out-task-id [out-task-id])
))
([^String stream ^List values]
+ (when debug?
+ (log-message "Emitting: " component-id " " stream " " values))
(let [out-tasks (ArrayList.)]
(fast-map-iter [[out-component grouper] (get stream->component->grouper stream)]
(when (= :direct grouper)
[2/2] storm git commit: Merge branch 'STORM-496' of
https://github.com/harshach/incubator-storm into STORM-496
Posted by sr...@apache.org.
Merge branch 'STORM-496' of https://github.com/harshach/incubator-storm into STORM-496
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/9517923b
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9517923b
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9517923b
Branch: refs/heads/master
Commit: 9517923b1d3652a3809d25e98994ad43beb1e534
Parents: 9f57ba9 3193307
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Sun Mar 8 10:35:28 2015 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Sun Mar 8 10:35:28 2015 -0700
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/task.clj | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/9517923b/storm-core/src/clj/backtype/storm/daemon/task.clj
----------------------------------------------------------------------