Roshan Naik created STORM-1539:
----------------------------------

             Summary: Improve Storm ACK-ing performance
                 Key: STORM-1539
                 URL: https://issues.apache.org/jira/browse/STORM-1539
             Project: Apache Storm
          Issue Type: Bug
            Reporter: Roshan Naik
            Assignee: Roshan Naik


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()



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to