From 3193307777b3155dc1524af0316aee139f349b23 Mon Sep 17 00:00:00 2001 From: Sriharsha Chintalapani Date: Thu, 26 Feb 2015 08:02:25 -0800 Subject: [PATCH] STORM-496. task.clj missing debug for logging spout and bolt emit values. --- storm-core/src/clj/backtype/storm/daemon/task.clj | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/storm-core/src/clj/backtype/storm/daemon/task.clj b/storm-core/src/clj/backtype/storm/daemon/task.clj index b037d214f67..da4abb3c65d 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)