Roshan Naik created STORM-2871: ---------------------------------- Summary: Performance optimizations for getOutgoingTasks Key: STORM-2871 URL: https://issues.apache.org/jira/browse/STORM-2871 Project: Apache Storm Issue Type: Improvement Reporter: Roshan Naik
Task.getOutgoingTasks() is in critical messaging path. Two observed bottlenecks in it : -[Looking up HashMap|] 'streamToGroupers'. Need to look into converting HashMap into Array lookup ? - [outTasks.addAll(compTasks)|https://github.com/apache/storm/blob/master/storm-client/src/jvm/org/apache/storm/daemon/Task.java#L139] seems to be impacting throughput as well. Identified by .. running ConstSpoutNullBoltTopo with 1 spout & bolt paralllelism (no Ack) and replacing this line with hard coded logic to add the single known bolt's taskID. -- This message was sent by Atlassian JIRA (v6.4.14#64029)