[STORM-289] Trident DRPC memory leak

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.2-incubating
• Fix Version/s: 0.9.2-incubating
• Component/s: storm-core
• Assignee: Gangrui Li
• Reporter: Gangrui Li
• Created: 22/Apr/14 02:09
• Updated: 05/Oct/15 02:19
• Resolved: 24/Apr/14 18:59

Description

storm.trident.spout.RichSpoutBatchTriggerer.java

Missing code "_msgIdToBatchId.put(r, batchIdVal);" in emit method.

As a consequence, ack/fail will get null batchId for each DRPC invoking, which makes _finishConditions map larger and larger until out of memory.