You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/05/28 21:04:29 UTC
[2/5] storm git commit: Also leave tuple type to log when task is null
Also leave tuple type to log when task is null
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/700c8ed1
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/700c8ed1
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/700c8ed1
Branch: refs/heads/master
Commit: 700c8ed166623d54d5dfa1aa57fc50ae522aaf93
Parents: 14477f4
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Thu Apr 23 08:42:35 2015 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Thu Apr 23 08:42:35 2015 +0900
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/worker.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/700c8ed1/storm-core/src/clj/backtype/storm/daemon/worker.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/worker.clj b/storm-core/src/clj/backtype/storm/daemon/worker.clj
index c4afcd9..0fddef5 100644
--- a/storm-core/src/clj/backtype/storm/daemon/worker.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/worker.clj
@@ -135,7 +135,7 @@
(let [remote (.get remoteMap node+port)]
(if (not-nil? task)
(.add remote (TaskMessage. task (.serialize serializer tuple)))
- (log-warn "Can't transfer tuple - task value is null. tuple information: " tuple))
+ (log-warn "Can't transfer tuple - task value is null. tuple type: " (type tuple) " and information: " tuple))
))))
(local-transfer local)
(disruptor/publish transfer-queue remoteMap)