Skip to content

Commit 2708e40

Browse files
author
Nathan Marz
committed
clarify comment about how tracked topologies work
1 parent dc8d388 commit 2708e40

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/clj/backtype/storm/testing.clj

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -503,7 +503,8 @@
503503
;; critical that this particular function is overridden here,
504504
;; since the transferred stat needs to be incremented at the moment
505505
;; of tuple emission (and not on a separate thread later) for
506-
;; topologies to be tracked correctly
506+
;; topologies to be tracked correctly. This is because "transferred" *must*
507+
;; be incremented before "processing".
507508
executor/mk-executor-transfer-fn
508509
(let [old# executor/mk-executor-transfer-fn]
509510
(fn [& args#]

0 commit comments

Comments
 (0)