Re:Apache Storm 1.0 released
by lovelearning on Tuesday April 12, 2016 @01:37PM
(#11481691)
From the issue log :
"Profiling a simple speed of light topology, shows that a good chunk of time of the SpoutOutputCollector.emit()
is spent in the clojure reduce() function.. which is part of the ACK-ing logic. Re-implementing this reduce() logic in java gives a big performance boost in both in the Spout.nextTuple() and Bolt.execute()"
"Profiling a simple speed of light topology, shows that a good chunk of time of the SpoutOutputCollector.emit() is spent in the clojure reduce() function.. which is part of the ACK-ing logic. Re-implementing this reduce() logic in java gives a big performance boost in both in the Spout.nextTuple() and Bolt.execute()"
[1]: https://issues.apache.org/jira/browse/STORM-1539