We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dc8d388 commit 2708e40Copy full SHA for 2708e40
src/clj/backtype/storm/testing.clj
@@ -503,7 +503,8 @@
503
;; critical that this particular function is overridden here,
504
;; since the transferred stat needs to be incremented at the moment
505
;; of tuple emission (and not on a separate thread later) for
506
- ;; topologies to be tracked correctly
+ ;; topologies to be tracked correctly. This is because "transferred" *must*
507
+ ;; be incremented before "processing".
508
executor/mk-executor-transfer-fn
509
(let [old# executor/mk-executor-transfer-fn]
510
(fn [& args#]
0 commit comments