Permalink
Browse files

make emitDirect work for spouts

  • Loading branch information...
1 parent e88aa5b commit a75d3780832544434c0db09179c4fa2097959137 @nathanmarz committed Apr 17, 2012
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/clj/backtype/storm/daemon/task.clj
@@ -312,7 +312,7 @@
)))
send-spout-msg (fn [out-stream-id values message-id out-task-id]
(let [out-tasks (if out-task-id
- (tasks-fn out-stream-id values out-task-id)
+ (tasks-fn out-task-id out-stream-id values)
(tasks-fn out-stream-id values))
root-id (MessageId/generateId)
rooted? (and message-id (> (storm-conf TOPOLOGY-ACKERS) 0))

0 comments on commit a75d378

Please sign in to comment.